databases

Documentation

Index

• type InvalidID
  • func (id InvalidID) Error() string
• type MessageDB
  • func NewMessageDB() *MessageDB
  • func (db MessageDB) FetchMessage(id string) (*pb.Message, error)
  • func (db MessageDB) FetchMessagesAfter(t time.Time) (*pb.MessageHistory, error)
  • func (db *MessageDB) GetMessage(id string) *pb.Message
  • func (db MessageDB) MaybeGetMessage(id string) (*pb.Message, error)
  • func (db *MessageDB) NewMessage(cMsg *pb.CreateMessage, userID string, sync ...bool) *pb.Message
  • func (db *MessageDB) PurgeCache()

Types

type InvalidID

type InvalidID struct {
}

func (InvalidID) Error

func (id InvalidID) Error() string

type MessageDB

type MessageDB struct {
	// TODO: Change to a channel cache when channels are implemented
	MessageCache       map[string]*pb.Message
	MessageCacheExpiry map[string]time.Time
}

func NewMessageDB

func NewMessageDB() *MessageDB

func (MessageDB) FetchMessage

func (db MessageDB) FetchMessage(id string) (*pb.Message, error)

func (MessageDB) FetchMessagesAfter

func (db MessageDB) FetchMessagesAfter(t time.Time) (*pb.MessageHistory, error)

func (*MessageDB) GetMessage

func (db *MessageDB) GetMessage(id string) *pb.Message

func (MessageDB) MaybeGetMessage

func (db MessageDB) MaybeGetMessage(id string) (*pb.Message, error)

func (*MessageDB) NewMessage

func (db *MessageDB) NewMessage(cMsg *pb.CreateMessage, userID string, sync ...bool) *pb.Message

func (*MessageDB) PurgeCache

func (db *MessageDB) PurgeCache()