storage

package
v1.0.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 9, 2017 License: BSD-3-Clause, BSD-3-Clause Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckAndRecordBodyHash added in v1.0.19 

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

Check the current message's body hash against all the body hashes we've seen, to prevent replays. If the header hash is new, add it to the set.

func CheckAndRecordPrevPointer added in v1.0.19 

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

Check the current message's header hash against all the prev pointers we've ever seen. If the current message is new, add it to the set.

Types

type BodyHashChecker added in v1.0.19 

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

type ByCtimeOrder added in v1.0.19 

type ByCtimeOrder []chat1.OutboxRecord

func (ByCtimeOrder) Len added in v1.0.19 

func (a ByCtimeOrder) Len() int

func (ByCtimeOrder) Less added in v1.0.19 

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

func (ByCtimeOrder) Swap added in v1.0.19 

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

type ByDatabaseOrder added in v1.0.19 

type ByDatabaseOrder []chat1.Conversation

func (ByDatabaseOrder) Len added in v1.0.19 

func (a ByDatabaseOrder) Len() int

func (ByDatabaseOrder) Less added in v1.0.19 

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

func (ByDatabaseOrder) Swap added in v1.0.19 

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

type Error added in v1.0.19 

type Error interface {
	error
	ShouldClear() bool
	Message() string
}

type Inbox added in v1.0.19 

type Inbox struct {
	libkb.Contextified

	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewInbox added in v1.0.19 

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

func (*Inbox) Merge added in v1.0.19 

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

func (*Inbox) NewConversation added in v1.0.19 

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

func (*Inbox) NewMessage added in v1.0.19 

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

func (*Inbox) Read added in v1.0.19 

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

func (*Inbox) ReadAll added in v1.0.19 

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

func (*Inbox) ReadMessage added in v1.0.19 

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

func (*Inbox) SetStatus added in v1.0.19 

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

func (*Inbox) TlfFinalize added in v1.0.19 

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

func (*Inbox) VersionSync added in v1.0.19 

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

type InternalError added in v1.0.19 

type InternalError struct {
	Msg string
}

func NewInternalError added in v1.0.19 

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

func (InternalError) Error added in v1.0.19 

func (e InternalError) Error() string

func (InternalError) Message added in v1.0.19 

func (e InternalError) Message() string

func (InternalError) ShouldClear added in v1.0.19 

func (e InternalError) ShouldClear() bool

type MiscError added in v1.0.19 

type MiscError struct {
	Msg string
}

func (MiscError) Error added in v1.0.19 

func (e MiscError) Error() string

func (MiscError) Message added in v1.0.19 

func (e MiscError) Message() string

func (MiscError) ShouldClear added in v1.0.19 

func (e MiscError) ShouldClear() bool

type MissError added in v1.0.19 

type MissError struct {
	Msg string
}

func (MissError) Error added in v1.0.19 

func (e MissError) Error() string

func (MissError) Message added in v1.0.19 

func (e MissError) Message() string

func (MissError) ShouldClear added in v1.0.19 

func (e MissError) ShouldClear() bool

type Outbox added in v1.0.19 

type Outbox struct {
	libkb.Contextified

	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewOutbox added in v1.0.19 

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

func (*Outbox) GetUID added in v1.0.19 

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

func (*Outbox) MarkAsError added in v1.0.19 

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

MarkAsError will either mark an existing record as an error, or it will add the passed record as an error with the specified error state

func (*Outbox) PullAllConversations added in v1.0.19 

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

PullAllConversations grabs all outbox entries for the current outbox, and optionally deletes them from storage

func (*Outbox) PushMessage added in v1.0.19 

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

func (*Outbox) RecordFailedAttempt added in v1.0.19 

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

RecordFailedAttempt will either modify an existing matching record (if sending) to next attempt number, or if the record doesn't exist it adds it in.

func (*Outbox) RemoveMessage added in v1.0.19 

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

func (*Outbox) RetryMessage added in v1.0.19 

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

func (*Outbox) SetClock added in v1.0.19 

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

func (*Outbox) SprinkleIntoThread added in v1.0.19 

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

type PrevChecker added in v1.0.19 

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

type RemoteError added in v1.0.19 

type RemoteError struct {
	Msg string
}

func (RemoteError) Error added in v1.0.19 

func (e RemoteError) Error() string

func (RemoteError) Message added in v1.0.19 

func (e RemoteError) Message() string

func (RemoteError) ShouldClear added in v1.0.19 

func (e RemoteError) ShouldClear() bool

type Storage 

type Storage struct {
	libkb.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func New 

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

func (*Storage) Fetch 

func (s *Storage) Fetch(ctx context.Context, conv chat1.Conversation,
	uid gregor1.UID, query *chat1.GetThreadQuery, pagination *chat1.Pagination) (chat1.ThreadView, Error)

func (*Storage) FetchMessages added in v1.0.19 

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

func (*Storage) FetchUpToLocalMaxMsgID added in v1.0.19 

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

func (*Storage) GetMaxMsgID added in v1.0.19 

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

func (*Storage) IsTLFIdentifyBroken added in v1.0.19 

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

func (*Storage) MaybeNuke 

func (s *Storage) MaybeNuke(force bool, err Error, convID chat1.ConversationID, uid gregor1.UID) Error

func (*Storage) Merge 

func (s *Storage) Merge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, msgs []chat1.MessageUnboxed) Error

func (*Storage) UpdateTLFIdentifyBreak added in v1.0.19 

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

type VersionMismatchError added in v1.0.19 

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

func NewVersionMismatchError added in v1.0.19 

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

func (VersionMismatchError) Error added in v1.0.19 

func (e VersionMismatchError) Error() string

func (VersionMismatchError) Message added in v1.0.19 

func (e VersionMismatchError) Message() string

func (VersionMismatchError) ShouldClear added in v1.0.19 

func (e VersionMismatchError) ShouldClear() bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.