stan_util

Documentation

Index

• type DurableConnection
  • func DurableConnect(stanClusterID, clientID, urls string, options ...stan.Option) (*DurableConnection, error)
  • func (c *DurableConnection) Check() error
  • func (c *DurableConnection) Close() error
  • func (c *DurableConnection) PublishAsync(subject string, data []byte, ah stan.AckHandler) (string, error)
  • func (c *DurableConnection) QueueSubscribe(subject, qgroup string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) error

Types

type DurableConnection

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

func DurableConnect

func DurableConnect(stanClusterID, clientID, urls string, options ...stan.Option) (*DurableConnection, error)

func (*DurableConnection) Check

func (c *DurableConnection) Check() error

func (*DurableConnection) Close

func (c *DurableConnection) Close() error

func (*DurableConnection) PublishAsync

func (c *DurableConnection) PublishAsync(subject string, data []byte, ah stan.AckHandler) (string, error)

func (*DurableConnection) QueueSubscribe

func (c *DurableConnection) QueueSubscribe(subject, qgroup string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) error