services

Documentation

Index

• type Notification
• type ServiceManager
  • func NewServiceManager(em *events.EventManager, initWg *sync.WaitGroup) *ServiceManager
  • func (sm *ServiceManager) HandleEvent(ctx context.Context, event events.EventMessage)

Types

type Notification

type Notification interface {
	Connect(context.Context) error
	Send(context.Context, string) error
	HandleEvent(context.Context, events.EventMessage)
	Disconnect() error
}

type ServiceManager

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

func NewServiceManager

func NewServiceManager(
	em *events.EventManager,
	initWg *sync.WaitGroup,
) *ServiceManager

func (*ServiceManager) HandleEvent

func (sm *ServiceManager) HandleEvent(ctx context.Context, event events.EventMessage)