Uses of Class
io.fluxzero.common.api.tracking.ClaimSegmentResult

Packages that use ClaimSegmentResult

Package	Description
io.fluxzero.sdk.tracking.client

Uses of ClaimSegmentResult in io.fluxzero.sdk.tracking.client

Methods in io.fluxzero.sdk.tracking.client that return types with arguments of type ClaimSegmentResult

Modifier and Type	Method	Description
CompletableFuture<ClaimSegmentResult>	CachingTrackingClient.claimSegment(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<ClaimSegmentResult>	LocalTrackingClient.claimSegment(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<ClaimSegmentResult>	TrackingClient.claimSegment(String trackerId, Long lastIndex, ConsumerConfiguration config)	Claims a processing segment for the given tracker.
CompletableFuture<ClaimSegmentResult>	WebsocketTrackingClient.claimSegment(String trackerId, Long lastIndex, ConsumerConfiguration config)	Requests a tracker segment using this client's message type and the consumer's filtering, waiting, and index-control settings; returns the asynchronous claim result.

Methods in io.fluxzero.sdk.tracking.client with parameters of type ClaimSegmentResult

Modifier and Type	Method	Description
protected MessageBatch	CachingTrackingClient.doWaitForCachedBatch(ConsumerConfiguration config, long minIndex, ClaimSegmentResult claim, Instant deadline)
protected MessageBatch	CachingTrackingClient.getMessageBatch(ConsumerConfiguration config, long minIndex, ClaimSegmentResult claim)
protected CompletableFuture<MessageBatch>	CachingTrackingClient.waitForCachedBatch(ConsumerConfiguration config, long minIndex, ClaimSegmentResult claim, Instant deadline)	Waits for locally cached messages.