streaming

package

v4.0.0-alpha.1 Latest Latest Go to latest Published: Jun 21, 2023 License: MIT Imports: 7 Imported by: 1

Details

This section is empty.

View Source

var ContextKeyDeliveries = reflect.TypeOf([]messaging.Delivery{}).String()

View Source

var Options singleton

View Source

var StreamOptions streamSingleton

View Source

var SubscriptionOptions subscriptionSingleton

func New(connector messaging.Connector, options ...option) messaging.ListenCloser

type ShutdownStrategy int

const (
	ShutdownStrategyCurrentBatch ShutdownStrategy = iota
	ShutdownStrategyImmediate
	ShutdownStrategyDrain
)

type Subscription struct {
	// contains filtered or unexported fields
}