inmem

Documentation

Index

• type Service
  • func NewService(logger *logger.Logger) *Service
  • func (s *Service) Close() error
  • func (s *Service) GetEventChannel(ctx context.Context) (chan *stategate.Event, *errorz.Error)
  • func (s *Service) GetMessageChannel(ctx context.Context) (chan *stategate.PeerMessage, *errorz.Error)
  • func (s *Service) PublishEvent(ctx context.Context, event *stategate.Event) *errorz.Error
  • func (s *Service) PublishMessage(ctx context.Context, message *stategate.PeerMessage) *errorz.Error

Types

type Service

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

func NewService

func NewService(logger *logger.Logger) *Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) GetEventChannel

func (s *Service) GetEventChannel(ctx context.Context) (chan *stategate.Event, *errorz.Error)

func (*Service) GetMessageChannel

func (s *Service) GetMessageChannel(ctx context.Context) (chan *stategate.PeerMessage, *errorz.Error)

func (*Service) PublishEvent

func (s *Service) PublishEvent(ctx context.Context, event *stategate.Event) *errorz.Error

func (*Service) PublishMessage

func (s *Service) PublishMessage(ctx context.Context, message *stategate.PeerMessage) *errorz.Error