stan

func AckOnSuccess ¶

func AckOnSuccess() broker.SubscribeOption

AckOnSuccess will automatically acknowledge messages when no error is returned

func ClientID ¶

func ClientID(clientID string) broker.Option

ClientID specify client id to connect

func ClusterID ¶

func ClusterID(clusterID string) broker.Option

ClusterID specify cluster id to connect

func ConnectRetry ¶

func ConnectRetry(v bool) broker.Option

ConnectRetry reconnect to broker in case of errors

func ConnectTimeout ¶

func ConnectTimeout(td time.Duration) broker.Option

ConnectTimeout timeout for connecting to broker -1 infinitive or time.Duration value

func DurableName ¶

func DurableName(name string) broker.Option

DurableName sets the DurableName for the subscriber

func NewBroker ¶

func NewBroker(opts ...broker.Option) broker.Broker

func Options ¶

func Options(opts stan.Options) broker.Option

Options accepts stan.Options

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