store

Documentation

Index

• Constants
• type IdleMessageStore
  • func (i *IdleMessageStore) StoreMessage(*messages.ChatMessage) error
  • func (i *IdleMessageStore) StoreOffline(message *messages.ChatMessage) error
• type KafkaConsumer
  • func NewKafkaConsumer(address []string) (*KafkaConsumer, error)
  • func (c *KafkaConsumer) Close() error
  • func (c *KafkaConsumer) ConsumeChannelMessage(cf func(m *messages.ChatMessage))
  • func (c *KafkaConsumer) ConsumeChatMessage(cf func(m *messages.ChatMessage))
  • func (c *KafkaConsumer) ConsumeOfflineMessage(cf func(m *messages.ChatMessage))
• type KafkaMessageStore
  • func NewKafkaProducer(address []string) (*KafkaMessageStore, error)
  • func (k *KafkaMessageStore) Close() error
  • func (k *KafkaMessageStore) NextSegmentSequence(id subscription.ChanID, info subscription.ChanInfo) (int64, int64, error)
  • func (k *KafkaMessageStore) StoreChannelMessage(ch subscription.ChanID, m *messages.ChatMessage) error
  • func (k *KafkaMessageStore) StoreMessage(message *messages.ChatMessage) error
  • func (k *KafkaMessageStore) StoreOffline(message *messages.ChatMessage) error
• type MessageStore
• type SubscriptionStore

Constants

const (
	KafkaChatMessageTopic        = "getaway_chat_message"
	KafkaChatOfflineMessageTopic = "getaway_chat_offline_message"
	KafkaChannelMessageTopic     = "gateway_channel_message"
)

Types

type IdleMessageStore

type IdleMessageStore struct {
}

func (*IdleMessageStore) StoreMessage

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

func (*IdleMessageStore) StoreOffline

func (i *IdleMessageStore) StoreOffline(message *messages.ChatMessage) error

type KafkaConsumer

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

func NewKafkaConsumer

func NewKafkaConsumer(address []string) (*KafkaConsumer, error)

func (*KafkaConsumer) Close

func (c *KafkaConsumer) Close() error

func (*KafkaConsumer) ConsumeChannelMessage

func (c *KafkaConsumer) ConsumeChannelMessage(cf func(m *messages.ChatMessage))

func (*KafkaConsumer) ConsumeChatMessage

func (c *KafkaConsumer) ConsumeChatMessage(cf func(m *messages.ChatMessage))

func (*KafkaConsumer) ConsumeOfflineMessage

func (c *KafkaConsumer) ConsumeOfflineMessage(cf func(m *messages.ChatMessage))

type KafkaMessageStore

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

func NewKafkaProducer

func NewKafkaProducer(address []string) (*KafkaMessageStore, error)

func (*KafkaMessageStore) Close

func (k *KafkaMessageStore) Close() error

func (*KafkaMessageStore) NextSegmentSequence

func (k *KafkaMessageStore) NextSegmentSequence(id subscription.ChanID, info subscription.ChanInfo) (int64, int64, error)

func (*KafkaMessageStore) StoreChannelMessage

func (k *KafkaMessageStore) StoreChannelMessage(ch subscription.ChanID, m *messages.ChatMessage) error

func (*KafkaMessageStore) StoreMessage

func (k *KafkaMessageStore) StoreMessage(message *messages.ChatMessage) error

func (*KafkaMessageStore) StoreOffline

func (k *KafkaMessageStore) StoreOffline(message *messages.ChatMessage) error

type MessageStore

type MessageStore interface {

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

	StoreOffline(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 {

	// NextSegmentSequence return the next segment of specified channel, and segment length.
	NextSegmentSequence(id subscription.ChanID, info subscription.ChanInfo) (int64, int64, error)

	// StoreChannelMessage stores a published message.
	StoreChannelMessage(ch subscription.ChanID, msg *messages.ChatMessage) error
}