Documentation ¶
Overview ¶
Package stan provides a NATS Streaming broker
Index ¶
- func AckOnSuccess() broker.SubscribeOption
- func ClientID(clientID string) broker.Option
- func ClusterID(clusterID string) broker.Option
- func ConnectRetry(v bool) broker.Option
- func ConnectTimeout(td time.Duration) broker.Option
- func DurableName(name string) broker.Option
- func NewBroker(opts ...broker.Option) broker.Broker
- func Options(opts stan.Options) broker.Option
- func ServerSubscriberOption(opts ...stan.SubscriptionOption) server.SubscriberOption
- func SubscribeContext(ctx context.Context) broker.SubscribeOption
- func SubscribeOption(opts ...stan.SubscriptionOption) broker.SubscribeOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AckOnSuccess ¶
func AckOnSuccess() broker.SubscribeOption
AckOnSuccess will automatically acknowledge messages when no error is returned
func ConnectRetry ¶ added in v1.5.3
ConnectRetry reconnect to broker in case of errors
func ConnectTimeout ¶ added in v1.5.3
ConnectTimeout timeout for connecting to broker -1 infinitive or time.Duration value
func DurableName ¶ added in v1.5.3
DurableName sets the DurableName for the subscriber
func ServerSubscriberOption ¶ added in v1.5.3
func ServerSubscriberOption(opts ...stan.SubscriptionOption) server.SubscriberOption
func SubscribeContext ¶
func SubscribeContext(ctx context.Context) broker.SubscribeOption
SubscribeContext set the context for broker.SubscribeOption
func SubscribeOption ¶
func SubscribeOption(opts ...stan.SubscriptionOption) broker.SubscribeOption
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.