pager

type InboxEntry ¶

type InboxEntry interface {
	GetMtime() gregor1.Time
	GetConvID() chat1.ConversationID
}

type InboxPager ¶

type InboxPager struct {
	Pager
}

inboxPager provides a convenient interface to pager for the inbox use case

func NewInboxPager() InboxPager

func (p InboxPager) MakePage(res []InboxEntry, reqed int) (*chat1.Pagination, error)

type InboxPagerFields ¶

type InboxPagerFields struct {
	Mtime  gregor1.Time         `codec:"M"`
	ConvID chat1.ConversationID `codec:"C"`
}

inboxPagerFields is the info that gives a total ordering on the inbox

func (i InboxPagerFields) GetConvID() chat1.ConversationID

func (i InboxPagerFields) GetMtime() gregor1.Time

type Message ¶

type Message interface {
	GetMessageID() chat1.MessageID
}

type Pager ¶

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

pager provides the getPage and makePage functions for implementing paging in the chat1 protocol

func NewPager() Pager

func (p Pager) GetPage(getcond func(bool) string, page *chat1.Pagination,
	pivot interface{}) (string, bool, error)

func (p Pager) MakePage(length, reqed int, next interface{}, prev interface{}) (*chat1.Pagination, error)

type ThreadPager ¶

type ThreadPager struct {
	Pager
}

threadPager provides a convenient interface to pager for the thread use case

func NewThreadPager() ThreadPager

func (p ThreadPager) MakeIndex(msg Message) ([]byte, error)

func (p ThreadPager) MakeIndexByID(msgID chat1.MessageID) ([]byte, error)

func (p ThreadPager) MakePage(res []Message, reqed int, maxDeletedUpto chat1.MessageID) (*chat1.Pagination, error)