package
0.23.0
Repository: https://github.com/google/knative-gcp.git
Documentation: pkg.go.dev

# Packages

No description provided by the author
No description provided by the author
No description provided by the author

# Functions

No description provided by the author
No description provided by the author
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.

# Constants

DefaultProbeCheckPort is the default port for checking sync pool health.

# Variables

No description provided by the author
No description provided by the author
ProviderSet provides the fanout and retry sync pools using the default client options.

# Structs

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.

# Interfaces

No description provided by the author

# Type aliases

Option is for providing individual option.
No description provided by the author