Struct Builder 

pub struct Builder<T>(/* private fields */);

A builder for StreamingSource

Implementations

impl Builder<DatasetRidStage>

pub fn dataset_rid(self, dataset_rid: DatasetRid) -> Builder<SessionCountStage>

Sets the dataset_rid field.

impl Builder<SessionCountStage>

pub fn session_count( self, session_count: SafeLong, ) -> Builder<TotalPointsCountStage>

Sets the session_count field.

impl Builder<TotalPointsCountStage>

pub fn total_points_count( self, total_points_count: SafeLong, ) -> Builder<EarliestCreatedAtStage>

Sets the total_points_count field.

impl Builder<EarliestCreatedAtStage>

pub fn earliest_created_at( self, earliest_created_at: Timestamp, ) -> Builder<LatestLastSeenAtStage>

Sets the earliest_created_at field.

impl Builder<LatestLastSeenAtStage>

pub fn latest_last_seen_at( self, latest_last_seen_at: Timestamp, ) -> Builder<AnyInProgressStage>

Sets the latest_last_seen_at field.

impl Builder<AnyInProgressStage>

pub fn any_in_progress(self, any_in_progress: bool) -> Builder<Complete>

Sets the any_in_progress field.

impl Builder<Complete>

pub fn source(self, source: impl Into<Option<StreamingSessionSource>>) -> Self

Sets the source field.

pub fn dataset_rid(self, dataset_rid: DatasetRid) -> Self

Sets the dataset_rid field.

pub fn session_count(self, session_count: SafeLong) -> Self

Sets the session_count field.

pub fn total_points_count(self, total_points_count: SafeLong) -> Self

Sets the total_points_count field.

pub fn earliest_created_at(self, earliest_created_at: Timestamp) -> Self

Sets the earliest_created_at field.

pub fn latest_last_seen_at(self, latest_last_seen_at: Timestamp) -> Self

Sets the latest_last_seen_at field.

pub fn merged_bounds(self, merged_bounds: impl Into<Option<Range>>) -> Self

Sets the merged_bounds field.

pub fn any_in_progress(self, any_in_progress: bool) -> Self

Sets the any_in_progress field.

pub fn build(self) -> StreamingSource

Consumes the builder, returning a StreamingSource.

Trait Implementations

impl Default for Builder<DatasetRidStage>

fn default() -> Self

Returns the “default value” for a type.

impl From<StreamingSource> for Builder<Complete>

fn from(v: StreamingSource) -> Self

Converts to this type from the input type.