event

Documentation

Index

• type EventsStreaming
  • func NewEventsStreaming() *EventsStreaming
  • func (es *EventsStreaming) Connect(clusterID string, options ...stan.Option) (err error)
  • func (es *EventsStreaming) NATS() stan.Conn
  • func (es *EventsStreaming) Publish(event *pb.Event) error
• type Repository

Types

type EventsStreaming

type EventsStreaming struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEventsStreaming

func NewEventsStreaming() *EventsStreaming

func (*EventsStreaming) Connect

func (es *EventsStreaming) Connect(clusterID string, options ...stan.Option) (err error)

func (*EventsStreaming) NATS

func (es *EventsStreaming) NATS() stan.Conn

NATS returns the current NATS connection.

func (*EventsStreaming) Publish

func (es *EventsStreaming) Publish(event *pb.Event) error

type Repository

type Repository interface {
	New(ctx context.Context, event *entities.Event) error
}

Repository of events.