api

Documentation

Index

• type DomainMessageServiceServer
  • func (s *DomainMessageServiceServer) QueryMessagesInRange(ctx context.Context, req *message.QueryMessagesInRangeRequest) (*message.QueryMessagesInRangeReply, error)
  • func (s *DomainMessageServiceServer) SendMessage(ctx context.Context, req *message.SendMessageRequest) (*message.SendMessageReply, error)
• type DomainPushServiceServer
  • func (s *DomainPushServiceServer) Messages(req *push.MessagesRequest, stream push.PushService_MessagesServer) error
• type MessageEventChannel

Types

type DomainMessageServiceServer

type DomainMessageServiceServer struct {
	MessageRepository   domain.MessageRepository
	Entropy             io.Reader
	MessageEventChannel MessageEventChannel
}

DomainMessageServiceServer is an implement of rpc MessageServiceServer using domain logic

func (*DomainMessageServiceServer) QueryMessagesInRange

func (s *DomainMessageServiceServer) QueryMessagesInRange(
	ctx context.Context,
	req *message.QueryMessagesInRangeRequest,
) (*message.QueryMessagesInRangeReply, error)

QueryMessagesInRange implements the rpc method QueryMessagesInRange

func (*DomainMessageServiceServer) SendMessage

func (s *DomainMessageServiceServer) SendMessage(
	ctx context.Context,
	req *message.SendMessageRequest,
) (*message.SendMessageReply, error)

SendMessage implements the rpc method SendMessage

type DomainPushServiceServer

type DomainPushServiceServer struct {
	MessageEventChannel MessageEventChannel
}

DomainPushServiceServer is an implement of rpc PushServiceServer using domain logic

func (*DomainPushServiceServer) Messages

func (s *DomainPushServiceServer) Messages(req *push.MessagesRequest, stream push.PushService_MessagesServer) error

Messages implements rpc method Messages

type MessageEventChannel

type MessageEventChannel interface {
	EmitNewMessageEvent(message *domain.Message) error
	Subscribe(chatroomID string, handler func(m *domain.Message)) (drain func(), err error)
	Drain() error
}

MessageEventChannel defines the interface of the message event channel