NewFanoutPool creates a new fanout handler pool.

NewHandler creates a new Handler.

NewOptions creates a Options.

NewRetryClient provides a retry CE client from a PubSub client and list of CE client options.

NewRetryPool creates a new retry handler pool.

StartSyncPool starts the sync pool.

WithDeliveryTimeout sets the DeliveryTimeout.

WithHandlerConcurrency sets HandlerConcurrency.

WithMaxConcurrentPerEvent sets MaxConcurrencyPerEvent.

WithPubsubReceiveSettings sets PubsubReceiveSettings.

WithTimeoutPerEvent sets TimeoutPerEvent.

DefaultProbeCheckPort is the default port for checking sync pool health.

ProviderSet provides the fanout and retry sync pools using the default client options.

FanoutPool is the sync pool for fanout handlers.

Handler pulls Pubsub messages as events and processes them with chain of processors.

Options holds all the options for create handler pool.

RetryPool is the sync pool for retry handlers.

Option is for providing individual option.