Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MemoryMessageEventChannel ¶
type MemoryMessageEventChannel struct {
// contains filtered or unexported fields
}
MemoryMessageEventChannel is an in-memory implement of api.MessageEventChannel
func NewMemoryMessageEventChannel ¶
func NewMemoryMessageEventChannel() *MemoryMessageEventChannel
NewMemoryMessageEventChannel creates a new MemoryMessageEventChannel
func (*MemoryMessageEventChannel) Drain ¶
func (ec *MemoryMessageEventChannel) Drain() error
Drain implements Drain
func (*MemoryMessageEventChannel) EmitNewMessageEvent ¶
func (ec *MemoryMessageEventChannel) EmitNewMessageEvent(message *domain.Message) error
EmitNewMessageEvent implements EmitNewMessageEvent
type MgoMessageRepository ¶
type MgoMessageRepository struct {
// contains filtered or unexported fields
}
MgoMessageRepository is an implementation of domain.MessageRepository using mongodb
func NewMgoMessageRepository ¶
func NewMgoMessageRepository(messageColl *mongo.Collection) *MgoMessageRepository
NewMgoMessageRepository creates a new MgoMessageRepository
func (*MgoMessageRepository) MessageByID ¶
func (repo *MgoMessageRepository) MessageByID(id string) (*domain.Message, error)
MessageByID implements MessageRepository.MessageByID
func (*MgoMessageRepository) MessageInRange ¶
func (repo *MgoMessageRepository) MessageInRange(chatroomID string, startID string, endID string) ([]*domain.Message, error)
MessageInRange implements MessageRepository.MessageInRange
func (*MgoMessageRepository) SaveMessage ¶
func (repo *MgoMessageRepository) SaveMessage(message *domain.Message) error
SaveMessage implements MessageRepository.SaveMessage
type NatsMessageEventChannel ¶
type NatsMessageEventChannel struct {
// contains filtered or unexported fields
}
NatsMessageEventChannel is an implement of api.MessageEventChannel using nats
func NewNatsMessageEventChannel ¶
func NewNatsMessageEventChannel(nc *nats.Conn, subjectPrefix string) *NatsMessageEventChannel
NewNatsMessageEventChannel creates a new NatsMessageEventChannel
func (*NatsMessageEventChannel) Drain ¶
func (ec *NatsMessageEventChannel) Drain() error
Drain implements Drain
func (*NatsMessageEventChannel) EmitNewMessageEvent ¶
func (ec *NatsMessageEventChannel) EmitNewMessageEvent(message *domain.Message) error
EmitNewMessageEvent implements EmitNewMessageEvent
Source Files