package
1.4.1
Repository: https://github.com/ankorstore/yokai-contrib.git
Documentation: pkg.go.dev

# Functions

DefaultSubscribeOptions is the default subscription options.
NewDefaultSubscriptionFactory returns a new DefaultSubscriptionFactory instance.
NewDefaultSubscriptionRegistry returns a new DefaultSubscriptionRegistry instance.
NewSubscription returns a new Subscription instance.
NormalizeSubscriptionName normalizes a subscription name for given projectID and subscriptionID to be compatible with the "projects/{projectID}/subscriptions/{subscriptionID}" format.
WithLegacyFlowControl sets the legacy flow control usage.
WithMaxExtension sets the max extension.
WithMaxExtensionPeriod sets the max extension period.
WithMaxOutstandingBytes sets the max outstanding bytes.
WithMaxOutstandingMessages sets the max outstanding messages.
WithMinExtensionPeriod sets the min extension period.
WithNumGoroutines sets the num of goroutines.

# Structs

DefaultSubscriptionFactory is the default SubscriptionFactory implementation.
DefaultSubscriptionRegistry is the default SubscriptionRegistry implementation.
Options represents subscription options.
Subscription represents a pub/sub subscription with an associated codec.Codec.

# Interfaces

SubscriptionFactory is the interface for Subscription factories.
SubscriptionRegistry is the interface for Subscription registries.

# Type aliases

SubscribeFunc represents the Subscription execution callback.
SubscribeOption represents subscription functional options.