eventer

Documentation

Index

• type Srv
  • func New(streamUrl string) *Srv
  • func (s *Srv) Connect(ctx context.Context) error
  • func (s *Srv) Disconnect(ctx context.Context) error
  • func (s *Srv) GetClient() nats.JetStreamContext
  • func (s *Srv) Publish(ctx context.Context, sub string, data interface{}) error

Types

type Srv

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

func New

func New(streamUrl string) *Srv

func (*Srv) Connect

func (s *Srv) Connect(ctx context.Context) error

func (*Srv) Disconnect

func (s *Srv) Disconnect(ctx context.Context) error

func (*Srv) GetClient

func (s *Srv) GetClient() nats.JetStreamContext

func (*Srv) Publish

func (s *Srv) Publish(ctx context.Context, sub string, data interface{}) error