messaging

type MessagingServer interface {
	Start() error
	Shutdown()
}

type Messenger interface {
	Publish(event *types.Event) error
	Subscribe(ctx context.Context, q *types.SubscribeQuery) (respCh chan *types.Event, err error)
}