chat

Documentation

Overview

Package chat provides a high-level store of chat messages

Index

• Constants
• Variables
• func NewDomainEmbeds() database.DomainEmbeds
• type Message
• type MessageID
• type SenderID
• type Store
  • func NewStore(db *database.DB) *Store
  • func (s *Store) AddMessage(ctx context.Context, m Message) (messageID MessageID, err error)
  • func (s *Store) GetMessagesByTopic(ctx context.Context, topic Topic, messagesLimit int64) (messages []Message, err error)
• type Topic

Constants

const DefaultMessagesLimit = 50

Variables

var MigrationFiles []string = []string{
	"1-initialize-schema-v0.1.7",
	"2-rename-user-to-identity-v0.1.11",
}

Functions

func NewDomainEmbeds

func NewDomainEmbeds() database.DomainEmbeds

Types

type Message

type Message struct {
	ID       MessageID
	Topic    Topic
	SendTime time.Time
	SenderID SenderID
	Body     string
}

type MessageID

type MessageID int64

type SenderID

type SenderID string

type Store

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

func NewStore

func NewStore(db *database.DB) *Store

func (*Store) AddMessage

func (s *Store) AddMessage(ctx context.Context, m Message) (messageID MessageID, err error)

func (*Store) GetMessagesByTopic

func (s *Store) GetMessagesByTopic(
	ctx context.Context, topic Topic, messagesLimit int64,
) (messages []Message, err error)

type Topic

type Topic string