handlers

Documentation

Index

• type EventHandler
  • func NewEventHandler(lc fx.Lifecycle, stream *stream.Stream, eventBus bus.Bus) *EventHandler
  • func (s *EventHandler) EventGetLastState(client stream.IStreamClient, query string, body []byte)
  • func (s *EventHandler) Shutdown(_ context.Context) error
  • func (s *EventHandler) Start(_ context.Context) error

Types

type EventHandler

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

func NewEventHandler

func NewEventHandler(lc fx.Lifecycle,
	stream *stream.Stream,
	eventBus bus.Bus) *EventHandler

func (*EventHandler) EventGetLastState

func (s *EventHandler) EventGetLastState(client stream.IStreamClient, query string, body []byte)

func (*EventHandler) Shutdown

func (s *EventHandler) Shutdown(_ context.Context) error

Shutdown ...

func (*EventHandler) Start

func (s *EventHandler) Start(_ context.Context) error

Start ...