stan

Documentation

Index

• type Conn
  • func ConnectSTAN(ctx context.Context, secretInterface corev1.SecretInterface, x dfv1.STAN, ...) (*Conn, error)
  • func (nsc *Conn) Close() error
  • func (nsc *Conn) IsClosed() bool
  • func (nsc *Conn) Publish(subject string, msg []byte) error
  • func (nsc *Conn) QueueSubscribe(subject, qgroup string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) (stan.Subscription, error)

Types

type Conn

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

func ConnectSTAN

func ConnectSTAN(ctx context.Context, secretInterface corev1.SecretInterface, x dfv1.STAN, clientID string) (*Conn, error)

func (*Conn) Close

func (nsc *Conn) Close() error

func (*Conn) IsClosed

func (nsc *Conn) IsClosed() bool

func (*Conn) Publish

func (nsc *Conn) Publish(subject string, msg []byte) error

func (*Conn) QueueSubscribe

func (nsc *Conn) QueueSubscribe(subject, qgroup string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) (stan.Subscription, error)