store

Documentation

Index

• type IdleMessageStore
  • func (i *IdleMessageStore) StoreMessage(*messages.ChatMessage) error
• type MessageStore
• type SubscriptionStore

Types

type IdleMessageStore

type IdleMessageStore struct {
}

func (*IdleMessageStore) StoreMessage

func (i *IdleMessageStore) StoreMessage(*messages.ChatMessage) error

type MessageStore

type MessageStore interface {

	// StoreMessage stores chat message to database
	StoreMessage(message *messages.ChatMessage) error
}

MessageStore is a store for messages, used to store chat messages in messaging.Interface, its many be called multiple times, but only the last updates will be stored.

type SubscriptionStore

type SubscriptionStore interface {

	// StoreMessage stores a published message.
	StoreMessage(ch subscription.ChanID, msg subscription.Message) error

	// StoreSeq stores the sequence number of a channel.
	StoreSeq(ch subscription.ChanID, seq int64) error
}