memory

Documentation

Index

• type Memory
  • func NewInMemory() *Memory
  • func (m *Memory) AdvancePointer(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (bool, error)
  • func (m *Memory) CountUnread(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (int64, error)
  • func (m *Memory) GetAllPointers(_ context.Context, chatID *commonpb.ChatId) ([]messaging.UserPointer, error)
  • func (m *Memory) GetBatchMessages(ctx context.Context, chatID *commonpb.ChatId, ...) ([]*messagingpb.Message, error)
  • func (m *Memory) GetMessage(ctx context.Context, chatID *commonpb.ChatId, messageID *messagingpb.MessageId) (*messagingpb.Message, error)
  • func (m *Memory) GetPagedMessages(ctx context.Context, chatID *commonpb.ChatId, options ...query.Option) ([]*messagingpb.Message, error)
  • func (m *Memory) GetPointers(_ context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) ([]*messagingpb.Pointer, error)
  • func (m *Memory) PutMessage(ctx context.Context, chatID *commonpb.ChatId, msg *messagingpb.Message) (*messagingpb.Message, error)
  • func (m *Memory) PutMessageLegacy(ctx context.Context, chatID *commonpb.ChatId, msg *messagingpb.Message) (*messagingpb.Message, error)
• type MessagesById
  • func (a MessagesById) Len() int
  • func (a MessagesById) Less(i, j int) bool
  • func (a MessagesById) Swap(i, j int)

Types

type Memory

type Memory struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewInMemory

func NewInMemory() *Memory

func (*Memory) AdvancePointer

func (m *Memory) AdvancePointer(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, pointer *messagingpb.Pointer) (bool, error)

func (*Memory) CountUnread

func (m *Memory) CountUnread(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, lastRead *messagingpb.MessageId, maxValue int64) (int64, error)

func (*Memory) GetAllPointers

func (m *Memory) GetAllPointers(_ context.Context, chatID *commonpb.ChatId) ([]messaging.UserPointer, error)

func (*Memory) GetBatchMessages

func (m *Memory) GetBatchMessages(ctx context.Context, chatID *commonpb.ChatId, messageIDs ...*messagingpb.MessageId) ([]*messagingpb.Message, error)

func (*Memory) GetMessage

func (m *Memory) GetMessage(ctx context.Context, chatID *commonpb.ChatId, messageID *messagingpb.MessageId) (*messagingpb.Message, error)

func (*Memory) GetPagedMessages

func (m *Memory) GetPagedMessages(ctx context.Context, chatID *commonpb.ChatId, options ...query.Option) ([]*messagingpb.Message, error)

func (*Memory) GetPointers

func (m *Memory) GetPointers(_ context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) ([]*messagingpb.Pointer, error)

func (*Memory) PutMessage

func (m *Memory) PutMessage(ctx context.Context, chatID *commonpb.ChatId, msg *messagingpb.Message) (*messagingpb.Message, error)

func (*Memory) PutMessageLegacy

func (m *Memory) PutMessageLegacy(ctx context.Context, chatID *commonpb.ChatId, msg *messagingpb.Message) (*messagingpb.Message, error)

type MessagesById

type MessagesById []*messagingpb.Message

func (MessagesById) Len

func (a MessagesById) Len() int

func (MessagesById) Less

func (a MessagesById) Less(i, j int) bool

func (MessagesById) Swap

func (a MessagesById) Swap(i, j int)