The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ContextKeyDeliveries = reflect.TypeOf([]messaging.Delivery{}).String()
View Source
var Options singleton
View Source
var SubscriptionOptions subscriptionSingleton
Functions ¶
Types ¶
type ShutdownStrategy ¶
type ShutdownStrategy int
const ( ShutdownStrategyCurrentBatch ShutdownStrategy = iota ShutdownStrategyImmediate ShutdownStrategyDrain )
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
func NewSubscription ¶
func NewSubscription(streamName string, options ...subscriptionOption) Subscription
Source Files
Click to show internal directories.
Click to hide internal directories.