base

Documentation

Index

• type STAN
  • func NewSTAN(url string, clusterID string, auth *eventbuscommon.Auth, ...) *STAN
  • func (n *STAN) MakeConnection(clientID string) (*STANConnection, error)
• type STANConnection
  • func (nsc *STANConnection) Close() error
  • func (nsc *STANConnection) IsClosed() bool

Types

type STAN

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

func NewSTAN

func NewSTAN(url string, clusterID string, auth *eventbuscommon.Auth, logger *zap.SugaredLogger) *STAN

NewSTAN returns a nats streaming driver

func (*STAN) MakeConnection

func (n *STAN) MakeConnection(clientID string) (*STANConnection, error)

type STANConnection

type STANConnection struct {
	NATSConn *nats.Conn
	STANConn stan.Conn

	NATSConnected bool
	STANConnected bool

	// defaultSubject  string
	ClientID string

	Logger *zap.SugaredLogger
}

func (*STANConnection) Close

func (nsc *STANConnection) Close() error

func (*STANConnection) IsClosed

func (nsc *STANConnection) IsClosed() bool