kafka

Feb 26, 2021

Changes in this version

type Service

+ 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

Feb 11, 2021

Changes in this version

+ type Service struct

+ func NewService(logger *logger.Logger, reader *kafka.Reader, writer *kafka.Writer) (*Service, error)

+ func (s *Service) Close() error

+ func (s *Service) GetChannel(ctx context.Context) (chan *stategate.Event, error)

+ func (s *Service) Publish(ctx context.Context, event *stategate.Event) error