storage

Jan 22, 2018

Changes in this version

+ type InsatiableResultCollector struct

+ func NewInsatiableResultCollector() *InsatiableResultCollector

+ func (s *InsatiableResultCollector) Done() bool

+ func (s *InsatiableResultCollector) Error(err Error) Error

+ func (s *InsatiableResultCollector) Name() string

+ func (s *InsatiableResultCollector) Push(msg chat1.MessageUnboxed)

+ func (s *InsatiableResultCollector) PushPlaceholder(chat1.MessageID) bool

+ func (s *InsatiableResultCollector) Result() []chat1.MessageUnboxed

+ func (s *InsatiableResultCollector) String() string

+ type MergeResult struct

+ DeletedHistory bool

Oct 3, 2017

Changes in this version

type Inbox

+ func (i *Inbox) MergeLocalMetadata(ctx context.Context, convs []chat1.ConversationLocal) (err Error)

Sep 15, 2017

Changes in this version

type Inbox

+ func (i *Inbox) TeamTypeChanged(ctx context.Context, vers chat1.InboxVers, convID chat1.ConversationID, ...) (err Error)

+ type InboxSyncRes struct

+ TeamTypeChanged bool

Aug 11, 2017

Changes in this version

+ func NewOutboxID() (chat1.OutboxID, error)

+ type HoleyResultCollector struct

+ func NewHoleyResultCollector(maxHoles int, rc ResultCollector) *HoleyResultCollector

+ func (h *HoleyResultCollector) Holes() int

+ func (h *HoleyResultCollector) PushPlaceholder(msgID chat1.MessageID) bool

type Inbox

+ func (i *Inbox) MembershipUpdate(ctx context.Context, vers chat1.InboxVers, userJoined []chat1.Conversation, ...) (err Error)

+ func (i *Inbox) SetAppNotificationSettings(ctx context.Context, vers chat1.InboxVers, convID chat1.ConversationID, ...) (err Error)

+ type InboxVersionSource struct

+ func NewInboxVersionSource(g *globals.Context) *InboxVersionSource

+ func (i *InboxVersionSource) GetInboxVersion(ctx context.Context, uid gregor1.UID) (chat1.InboxVers, error)

type ResultCollector

+ PushPlaceholder func(msgID chat1.MessageID) bool

type SimpleResultCollector

+ func (s *SimpleResultCollector) PushPlaceholder(chat1.MessageID) bool

type Storage

+ func (s *Storage) ResultCollectorFromQuery(ctx context.Context, query *chat1.GetThreadQuery, pagination *chat1.Pagination) ResultCollector

type TypedResultCollector

+ func (t *TypedResultCollector) PushPlaceholder(msgID chat1.MessageID) bool

May 1, 2017

Changes in this version

+ type ConversationFailureBox struct

+ func NewConversationFailureBox(g *globals.Context, uid gregor1.UID, key string) *ConversationFailureBox

+ func (f *ConversationFailureBox) Failure(ctx context.Context, convID chat1.ConversationID) (err Error)

+ func (f *ConversationFailureBox) Read(ctx context.Context) (res []ConversationFailureRecord, err Error)

+ func (f *ConversationFailureBox) Success(ctx context.Context, convID chat1.ConversationID) (err Error)

+ type ConversationFailureRecord struct

+ Attempts int

+ ConvID chat1.ConversationID

+ LastAttempt gregor1.Time

Apr 13, 2017

Changes in this version

+ var DefaultSecretUI = func() libkb.SecretUI

type Inbox

+ func (i *Inbox) Clear(ctx context.Context) (err Error)

+ func (i *Inbox) ServerVersion(ctx context.Context) (vers int, err Error)

+ func (i *Inbox) Sync(ctx context.Context, vers chat1.InboxVers, convs []chat1.Conversation) (err Error)

+ func (i *Inbox) Version(ctx context.Context) (vers chat1.InboxVers, err Error)

+ type ResultCollector interface

+ Done func() bool

+ Error func(err Error) Error

+ Name func() string

+ Push func(msg chat1.MessageUnboxed)

+ Result func() []chat1.MessageUnboxed

+ String func() string

+ type SecretUI struct

+ func (d SecretUI) GetPassphrase(pinentry keybase1.GUIEntryArg, terminal *keybase1.SecretEntryArg) (keybase1.GetPassphraseRes, error)

+ type ServerVersions struct

+ func NewServerVersions(g *libkb.GlobalContext) *ServerVersions

+ func (s *ServerVersions) Fetch(ctx context.Context) (chat1.ServerCacheVers, error)

+ func (s *ServerVersions) MatchBodies(ctx context.Context, vers int) (int, error)

+ func (s *ServerVersions) MatchInbox(ctx context.Context, vers int) (int, error)

+ func (s *ServerVersions) Set(ctx context.Context, vers chat1.ServerCacheVers) (err error)

+ type SimpleResultCollector struct

+ func NewSimpleResultCollector(num int) *SimpleResultCollector

+ func (s *SimpleResultCollector) Done() bool

+ func (s *SimpleResultCollector) Error(err Error) Error

+ func (s *SimpleResultCollector) Name() string

+ func (s *SimpleResultCollector) Push(msg chat1.MessageUnboxed)

+ func (s *SimpleResultCollector) Result() []chat1.MessageUnboxed

+ func (s *SimpleResultCollector) String() string

+ type TypedResultCollector struct

+ func NewTypedResultCollector(num int, typs []chat1.MessageType) *TypedResultCollector

+ func (t *TypedResultCollector) Done() bool

+ func (t *TypedResultCollector) Error(err Error) Error

+ func (t *TypedResultCollector) Name() string

+ func (t *TypedResultCollector) Push(msg chat1.MessageUnboxed)

+ func (t *TypedResultCollector) Result() []chat1.MessageUnboxed

+ func (t *TypedResultCollector) String() string

Mar 9, 2017

Changes in this version

+ func CheckAndRecordBodyHash(g *libkb.GlobalContext, bodyHash chat1.Hash, uniqueMsgID chat1.MessageID, ...) error

+ func CheckAndRecordPrevPointer(g *libkb.GlobalContext, msgID chat1.MessageID, convID chat1.ConversationID, ...) error

+ type BodyHashChecker func(bodyHash chat1.Hash, uniqueMsgID chat1.MessageID, ...) error

+ type ByCtimeOrder []chat1.OutboxRecord

+ func (a ByCtimeOrder) Len() int

+ func (a ByCtimeOrder) Less(i, j int) bool

+ func (a ByCtimeOrder) Swap(i, j int)

+ type ByDatabaseOrder []chat1.Conversation

+ func (a ByDatabaseOrder) Len() int

+ func (a ByDatabaseOrder) Less(i, j int) bool

+ func (a ByDatabaseOrder) Swap(i, j int)

+ type Error interface

+ Message func() string

+ ShouldClear func() bool

+ type Inbox struct

+ func NewInbox(g *libkb.GlobalContext, uid gregor1.UID, getSecretUI func() libkb.SecretUI) *Inbox

+ func (i *Inbox) Merge(ctx context.Context, vers chat1.InboxVers, convsIn []chat1.Conversation, ...) (err Error)

+ func (i *Inbox) NewConversation(ctx context.Context, vers chat1.InboxVers, conv chat1.Conversation) (err Error)

+ func (i *Inbox) NewMessage(ctx context.Context, vers chat1.InboxVers, convID chat1.ConversationID, ...) (err Error)

+ func (i *Inbox) Read(ctx context.Context, query *chat1.GetInboxQuery, p *chat1.Pagination) (vers chat1.InboxVers, res []chat1.Conversation, pagination *chat1.Pagination, ...)

+ func (i *Inbox) ReadAll(ctx context.Context) (vers chat1.InboxVers, res []chat1.Conversation, err Error)

+ func (i *Inbox) ReadMessage(ctx context.Context, vers chat1.InboxVers, convID chat1.ConversationID, ...) (err Error)

+ func (i *Inbox) SetStatus(ctx context.Context, vers chat1.InboxVers, convID chat1.ConversationID, ...) (err Error)

+ func (i *Inbox) TlfFinalize(ctx context.Context, vers chat1.InboxVers, convIDs []chat1.ConversationID, ...) (err Error)

+ func (i *Inbox) VersionSync(ctx context.Context, vers chat1.InboxVers) (err Error)

+ type InternalError struct

+ Msg string

+ func NewInternalError(ctx context.Context, d utils.DebugLabeler, msg string, args ...interface{}) InternalError

+ func (e InternalError) Error() string

+ func (e InternalError) Message() string

+ func (e InternalError) ShouldClear() bool

+ type MiscError struct

+ Msg string

+ func (e MiscError) Error() string

+ func (e MiscError) Message() string

+ func (e MiscError) ShouldClear() bool

+ type MissError struct

+ Msg string

+ func (e MissError) Error() string

+ func (e MissError) Message() string

+ func (e MissError) ShouldClear() bool

+ type Outbox struct

+ func NewOutbox(g *libkb.GlobalContext, uid gregor1.UID, getSecretUI func() libkb.SecretUI) *Outbox

+ func (o *Outbox) GetUID() gregor1.UID

+ func (o *Outbox) MarkAsError(ctx context.Context, obr chat1.OutboxRecord, errRec chat1.OutboxStateError) error

+ func (o *Outbox) PullAllConversations(ctx context.Context, includeErrors bool, remove bool) ([]chat1.OutboxRecord, error)

+ func (o *Outbox) PushMessage(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, ...) (rec chat1.OutboxRecord, err Error)

+ func (o *Outbox) RecordFailedAttempt(ctx context.Context, oldObr chat1.OutboxRecord) error

+ func (o *Outbox) RemoveMessage(ctx context.Context, obid chat1.OutboxID) error

+ func (o *Outbox) RetryMessage(ctx context.Context, obid chat1.OutboxID) error

+ func (o *Outbox) SetClock(cl clockwork.Clock)

+ func (o *Outbox) SprinkleIntoThread(ctx context.Context, convID chat1.ConversationID, thread *chat1.ThreadView) error

+ type PrevChecker func(msgID chat1.MessageID, convID chat1.ConversationID, ...) error

+ type RemoteError struct

+ Msg string

+ func (e RemoteError) Error() string

+ func (e RemoteError) Message() string

+ func (e RemoteError) ShouldClear() bool

type Storage

+ func (s *Storage) FetchMessages(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) ([]*chat1.MessageUnboxed, error)

+ func (s *Storage) FetchUpToLocalMaxMsgID(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (chat1.ThreadView, Error)

+ func (s *Storage) GetMaxMsgID(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID) (chat1.MessageID, error)

+ func (s *Storage) IsTLFIdentifyBroken(ctx context.Context, tlfID chat1.TLFID) bool

+ func (s *Storage) UpdateTLFIdentifyBreak(ctx context.Context, tlfID chat1.TLFID, breaks []keybase1.TLFIdentifyFailure) error

+ type VersionMismatchError struct

+ func NewVersionMismatchError(oldVers chat1.InboxVers, newVers chat1.InboxVers) VersionMismatchError

+ func (e VersionMismatchError) Error() string

+ func (e VersionMismatchError) Message() string

+ func (e VersionMismatchError) ShouldClear() bool

Oct 26, 2016

Changes in this version

+ type Storage struct

+ func New(g *libkb.GlobalContext, getSecretUI func() libkb.SecretUI) *Storage

+ func (s *Storage) Fetch(ctx context.Context, conv chat1.Conversation, uid gregor1.UID, ...) (chat1.ThreadView, libkb.ChatStorageError)

+ func (s *Storage) MaybeNuke(force bool, err libkb.ChatStorageError, convID chat1.ConversationID, ...) libkb.ChatStorageError

+ func (s *Storage) Merge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) libkb.ChatStorageError