events

Documentation

Index

• type Eventus
  • func NewEventus(logger *zap.Logger, url string) (*Eventus, error)
  • func (e *Eventus) Stop() error
• type IEvent

Types

type Eventus

type Eventus struct {
	NC *nats.Conn
	JS nats.JetStreamContext
	// contains filtered or unexported fields
}

func NewEventus

func NewEventus(logger *zap.Logger, url string) (*Eventus, error)

func (*Eventus) Stop

func (e *Eventus) Stop() error

type IEvent

type IEvent interface {
	GetName() string
}