Documentation ¶
Index ¶
- Constants
- Variables
- func CreateNameInfoSource(ctx context.Context, g *globals.Context, ...) types.NameInfoSource
- func CurrentUID(g *globals.Context) (keybase1.UID, error)
- func FindConversations(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ...) (res []chat1.ConversationLocal, err error)
- func GetInboxQueryNameInfo(ctx context.Context, g *globals.Context, lquery *chat1.GetInboxLocalQuery) (res types.NameInfo, err error)
- func GetMessage(ctx context.Context, g *globals.Context, uid gregor1.UID, ...) (chat1.MessageUnboxed, error)
- func GetMessages(ctx context.Context, g *globals.Context, uid gregor1.UID, ...) ([]chat1.MessageUnboxed, error)
- func GetTopicNameState(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ...) (res chat1.TopicNameState, err error)
- func IsRekeyError(err error) (typ chat1.ConversationErrorType, ok bool)
- func JoinConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ...) (err error)
- func JoinConversationByName(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ...) (err error)
- func LeaveConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ...) (err error)
- func LocalOnlyReplyFill(enabled bool) func(*ReplyFiller)
- func NewConversation(ctx context.Context, g *globals.Context, uid gregor1.UID, tlfName string, ...) (chat1.ConversationLocal, error)
- func NewConversationSource(g *globals.Context, typ string, boxer *Boxer, storage *storage.Storage, ...) types.ConversationSource
- func NewConversationWithMemberSourceConv(ctx context.Context, g *globals.Context, uid gregor1.UID, tlfName string, ...) (chat1.ConversationLocal, error)
- func NewCtxFactory(g *globals.Context) types.ContextFactory
- func NewFTLError(s string) error
- func NewInboxSource(g *globals.Context, typ string, badger *badges.Badger, ...) types.InboxSource
- func NewKeyFinder(g *globals.Context) types.KeyFinder
- func NewKeyFinderMock(cryptKeys []keybase1.CryptKey) types.KeyFinder
- func NewPermanentUnboxingError(inner error) types.UnboxingError
- func NewTransientUnboxingError(inner error) types.UnboxingError
- func PresentConversationLocalWithFetchRetry(ctx context.Context, g *globals.Context, uid gregor1.UID, ...) (res *chat1.InboxUIItem)
- func PreviewConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ...) (err error)
- func RecentConversationParticipants(ctx context.Context, g *globals.Context, myUID gregor1.UID) ([]gregor1.UID, error)
- func TLFIDToTeamID(tlfID chat1.TLFID) (keybase1.TeamID, error)
- type AttachmentHTTPSrv
- func (r *AttachmentHTTPSrv) GetAttachmentFetcher() types.AttachmentFetcher
- func (r *AttachmentHTTPSrv) GetGiphyGalleryURL(ctx context.Context, convID chat1.ConversationID, tlfName string, ...) string
- func (r *AttachmentHTTPSrv) GetGiphyURL(ctx context.Context, giphyURL string) string
- func (r *AttachmentHTTPSrv) GetPendingPreviewURL(ctx context.Context, outboxID chat1.OutboxID) string
- func (r *AttachmentHTTPSrv) GetURL(ctx context.Context, convID chat1.ConversationID, msgID chat1.MessageID, ...) string
- func (r *AttachmentHTTPSrv) GetUnfurlAssetURL(ctx context.Context, convID chat1.ConversationID, asset chat1.Asset) string
- func (r *AttachmentHTTPSrv) OnDbNuke(mctx libkb.MetaContext) error
- func (r *AttachmentHTTPSrv) Sign(payload []byte) ([]byte, error)
- type AttachmentUploadError
- type BackgroundConvLoader
- func (b *BackgroundConvLoader) Queue(ctx context.Context, job types.ConvLoaderJob) error
- func (b *BackgroundConvLoader) Resume(ctx context.Context) bool
- func (b *BackgroundConvLoader) Start(ctx context.Context, uid gregor1.UID)
- func (b *BackgroundConvLoader) Stop(ctx context.Context) chan struct{}
- func (b *BackgroundConvLoader) Suspend(ctx context.Context) (canceled bool)
- type BackgroundEphemeralPurger
- func (b *BackgroundEphemeralPurger) Queue(ctx context.Context, purgeInfo chat1.EphemeralPurgeInfo) error
- func (b *BackgroundEphemeralPurger) SetClock(clock clockwork.Clock)
- func (b *BackgroundEphemeralPurger) Start(ctx context.Context, uid gregor1.UID)
- func (b *BackgroundEphemeralPurger) Stop(ctx context.Context) (ch chan struct{})
- type BlockingSender
- func (s *BlockingSender) Prepare(ctx context.Context, plaintext chat1.MessagePlaintext, ...) (res types.SenderPrepareResult, err error)
- func (s *BlockingSender) Send(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, ...) (obid chat1.OutboxID, boxed *chat1.MessageBoxed, err error)
- func (s *BlockingSender) SetClock(clock clockwork.Clock)
- func (s *BlockingSender) Sign(payload []byte) ([]byte, error)
- type BodyHashInvalid
- type Boxer
- func (b *Boxer) BoxMessage(ctx context.Context, msg chat1.MessagePlaintext, ...) (res chat1.MessageBoxed, err error)
- func (b *Boxer) CompareTlfNames(ctx context.Context, tlfName1, tlfName2 string, ...) (bool, error)
- func (b *Boxer) GetBoxedVersion(msg chat1.MessagePlaintext) (chat1.MessageBoxedVersion, error)
- func (b *Boxer) GetEncryptionInfo(ctx context.Context, msg *chat1.MessagePlaintext, ...) (res types.BoxerEncryptionInfo, err error)
- func (b *Boxer) SetClock(clock clockwork.Clock)
- func (b *Boxer) UnboxMessage(ctx context.Context, boxed chat1.MessageBoxed, ...) (m chat1.MessageUnboxed, uberr types.UnboxingError)
- func (b *Boxer) UnboxMessages(ctx context.Context, boxed []chat1.MessageBoxed, ...) (unboxed []chat1.MessageUnboxed, err error)
- func (b *Boxer) UnboxThread(ctx context.Context, boxed chat1.ThreadViewBoxed, ...) (thread chat1.ThreadView, err error)
- func (b *Boxer) ValidSenderKey(ctx context.Context, sender gregor1.UID, key []byte, ctime gregor1.Time) (found, validAtCTime bool, revoked *gregor1.Time, unboxErr types.UnboxingError)
- type BoxingCryptKeysError
- type BoxingError
- type CachingAttachmentFetcher
- func (c *CachingAttachmentFetcher) DeleteAssets(ctx context.Context, convID chat1.ConversationID, assets []chat1.Asset, ...) (err error)
- func (c *CachingAttachmentFetcher) FetchAttachment(ctx context.Context, w io.Writer, convID chat1.ConversationID, ...) (err error)
- func (c *CachingAttachmentFetcher) IsAssetLocal(ctx context.Context, asset chat1.Asset) (found bool, err error)
- func (c *CachingAttachmentFetcher) OnDbNuke(mctx libkb.MetaContext) error
- func (c *CachingAttachmentFetcher) PutUploadedAsset(ctx context.Context, filename string, asset chat1.Asset) (err error)
- func (c *CachingAttachmentFetcher) StreamAttachment(ctx context.Context, convID chat1.ConversationID, asset chat1.Asset, ...) (res io.ReadSeeker, err error)
- type CachingIdentifyNotifier
- type CachingUPAKFinder
- func (u *CachingUPAKFinder) CheckKIDForUID(ctx context.Context, uid keybase1.UID, kid keybase1.KID) (found bool, revokedAt *keybase1.KeybaseTime, deleted bool, err error)
- func (u *CachingUPAKFinder) LookupUsernameAndDevice(ctx context.Context, uid keybase1.UID, deviceID keybase1.DeviceID) (username libkb.NormalizedUsername, deviceName string, deviceType string, ...)
- type ChatThreadConsistencyError
- type ConsistencyErrorCode
- type ConversationRetry
- type CtxFactory
- type DecryptionKeyNotFoundError
- type Deliverer
- func (s *Deliverer) ActiveDeliveries(ctx context.Context) (res []chat1.OutboxRecord, err error)
- func (s *Deliverer) Connected(ctx context.Context)
- func (s *Deliverer) Disconnected(ctx context.Context)
- func (s *Deliverer) ForceDeliverLoop(ctx context.Context)
- func (s *Deliverer) IsDelivering() bool
- func (s *Deliverer) IsOffline(ctx context.Context) bool
- func (s *Deliverer) NextFailure() (chan []chat1.OutboxRecord, func())
- func (s *Deliverer) Queue(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, ...) (obr chat1.OutboxRecord, err error)
- func (s *Deliverer) SetClock(clock clockwork.Clock)
- func (s *Deliverer) SetSender(sender types.Sender)
- func (s *Deliverer) Start(ctx context.Context, uid gregor1.UID)
- func (s *Deliverer) Stop(ctx context.Context) chan struct{}
- type DelivererInfoError
- type DevConversationBackedStorage
- type DummyIdentifyNotifier
- type DuplicateTopicNameError
- type EphemeralAlreadyExpiredError
- type EphemeralUnboxingError
- type FTLError
- type FetchRetrier
- func (f *FetchRetrier) Connected(ctx context.Context)
- func (f *FetchRetrier) Disconnected(ctx context.Context)
- func (f *FetchRetrier) Failure(ctx context.Context, uid gregor1.UID, desc types.RetryDescription) (err error)
- func (f *FetchRetrier) Force(ctx context.Context)
- func (f *FetchRetrier) IsOffline(ctx context.Context) bool
- func (f *FetchRetrier) Rekey(ctx context.Context, name string, membersType chat1.ConversationMembersType, ...)
- func (f *FetchRetrier) SetClock(clock clockwork.Clock)
- func (f *FetchRetrier) Start(ctx context.Context, uid gregor1.UID)
- func (f *FetchRetrier) Stop(ctx context.Context) chan struct{}
- func (f *FetchRetrier) Success(ctx context.Context, uid gregor1.UID, desc types.RetryDescription) (err error)
- type FetchType
- type FlipManager
- func (m *FlipManager) CLogf(ctx context.Context, fmt string, args ...interface{})
- func (m *FlipManager) Clock() clockwork.Clock
- func (m *FlipManager) DescribeFlipText(ctx context.Context, text string) string
- func (m *FlipManager) HasActiveGames(ctx context.Context) bool
- func (m *FlipManager) IsFlipConversationCreated(ctx context.Context, outboxID chat1.OutboxID) (convID chat1.ConversationID, status types.FlipSendStatus)
- func (m *FlipManager) LoadFlip(ctx context.Context, uid gregor1.UID, hostConvID chat1.ConversationID, ...) (res chan chat1.UICoinFlipStatus, err chan error)
- func (m *FlipManager) MaybeInjectFlipMessage(ctx context.Context, boxedMsg chat1.MessageBoxed, inboxVers chat1.InboxVers, ...) bool
- func (m *FlipManager) Me() flip.UserDevice
- func (m *FlipManager) SendChat(ctx context.Context, convID chat1.ConversationID, gameID chat1.FlipGameID, ...) (err error)
- func (m *FlipManager) ServerTime(ctx context.Context) (res time.Time, err error)
- func (m *FlipManager) ShouldCommit(ctx context.Context) bool
- func (m *FlipManager) Start(ctx context.Context, uid gregor1.UID)
- func (m *FlipManager) StartFlip(ctx context.Context, uid gregor1.UID, hostConvID chat1.ConversationID, ...) (err error)
- func (m *FlipManager) Stop(ctx context.Context) (ch chan struct{})
- type FlipVisualizer
- type FullInboxRetry
- type HeaderMismatchError
- type Helper
- func (h *Helper) FindConversations(ctx context.Context, name string, topicName *string, topicType chat1.TopicType, ...) ([]chat1.ConversationLocal, error)
- func (h *Helper) FindConversationsByID(ctx context.Context, convIDs []chat1.ConversationID) ([]chat1.ConversationLocal, error)
- func (h *Helper) GetChannelTopicName(ctx context.Context, teamID keybase1.TeamID, topicType chat1.TopicType, ...) (topicName string, err error)
- func (h *Helper) GetMessage(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) (chat1.MessageUnboxed, error)
- func (h *Helper) GetMessages(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) ([]chat1.MessageUnboxed, error)
- func (h *Helper) JoinConversationByID(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (err error)
- func (h *Helper) JoinConversationByName(ctx context.Context, uid gregor1.UID, tlfName, topicName string, ...) (err error)
- func (h *Helper) LeaveConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (err error)
- func (h *Helper) NewConversation(ctx context.Context, uid gregor1.UID, tlfName string, topicName *string, ...) (chat1.ConversationLocal, error)
- func (h *Helper) NewConversationWithMemberSourceConv(ctx context.Context, uid gregor1.UID, tlfName string, topicName *string, ...) (chat1.ConversationLocal, error)
- func (h *Helper) SendMsgByID(ctx context.Context, convID chat1.ConversationID, tlfName string, ...) error
- func (h *Helper) SendMsgByIDNonblock(ctx context.Context, convID chat1.ConversationID, tlfName string, ...) (chat1.OutboxID, error)
- func (h *Helper) SendMsgByName(ctx context.Context, name string, topicName *string, ...) error
- func (h *Helper) SendMsgByNameNonblock(ctx context.Context, name string, topicName *string, ...) (chat1.OutboxID, error)
- func (h *Helper) SendTextByID(ctx context.Context, convID chat1.ConversationID, tlfName string, text string) error
- func (h *Helper) SendTextByIDNonblock(ctx context.Context, convID chat1.ConversationID, tlfName string, text string, ...) (chat1.OutboxID, error)
- func (h *Helper) SendTextByName(ctx context.Context, name string, topicName *string, ...) error
- func (h *Helper) SendTextByNameNonblock(ctx context.Context, name string, topicName *string, ...) (chat1.OutboxID, error)
- func (h *Helper) UpgradeKBFSToImpteam(ctx context.Context, tlfName string, tlfID chat1.TLFID, public bool) (err error)
- func (h *Helper) UserReacjis(ctx context.Context, uid gregor1.UID) keybase1.UserReacjis
- type HybridConversationSource
- func (s *HybridConversationSource) AcquireConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) error
- func (s *HybridConversationSource) Clear(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID) error
- func (s *HybridConversationSource) ClearFromDelete(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) bool
- func (s HybridConversationSource) DeleteAssets(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (s *HybridConversationSource) EphemeralPurge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (newPurgeInfo *chat1.EphemeralPurgeInfo, explodedMsgs []chat1.MessageUnboxed, ...)
- func (s *HybridConversationSource) Expunge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (err error)
- func (s *HybridConversationSource) GetMessages(ctx context.Context, conv types.UnboxConversationInfo, uid gregor1.UID, ...) (res []chat1.MessageUnboxed, err error)
- func (s *HybridConversationSource) GetMessagesWithRemotes(ctx context.Context, conv chat1.Conversation, uid gregor1.UID, ...) ([]chat1.MessageUnboxed, error)
- func (s *HybridConversationSource) GetUnreadline(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (unreadlineID *chat1.MessageID, err error)
- func (s HybridConversationSource) MarkAsRead(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (err error)
- func (s *HybridConversationSource) Pull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (thread chat1.ThreadView, err error)
- func (s HybridConversationSource) PullFull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (res chat1.ThreadView, err error)
- func (s *HybridConversationSource) PullLocalOnly(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (tv chat1.ThreadView, err error)
- func (s *HybridConversationSource) Push(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (decmsg chat1.MessageUnboxed, continuousUpdate bool, err error)
- func (s *HybridConversationSource) PushUnboxed(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (continuousUpdate bool, err error)
- func (s *HybridConversationSource) ReleaseConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID)
- func (s HybridConversationSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
- func (s HybridConversationSource) Sign(payload []byte) ([]byte, error)
- func (s HybridConversationSource) TransformSupersedes(ctx context.Context, unboxInfo types.UnboxConversationInfo, uid gregor1.UID, ...) ([]chat1.MessageUnboxed, error)
- type HybridInboxSource
- func (s *HybridInboxSource) Clear(ctx context.Context, uid gregor1.UID) error
- func (b HybridInboxSource) Connected(ctx context.Context)
- func (s *HybridInboxSource) ConversationsUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (err error)
- func (b HybridInboxSource) Disconnected(ctx context.Context)
- func (s *HybridInboxSource) Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (*chat1.ConversationLocal, error)
- func (b HybridInboxSource) GetInboxQueryLocalToRemote(ctx context.Context, lquery *chat1.GetInboxLocalQuery) (rquery *chat1.GetInboxQuery, info types.NameInfo, err error)
- func (b HybridInboxSource) IsMember(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (bool, error)
- func (b HybridInboxSource) IsOffline(ctx context.Context) bool
- func (s *HybridInboxSource) IsTeam(ctx context.Context, uid gregor1.UID, item string) (res bool, err error)
- func (b HybridInboxSource) Localize(ctx context.Context, uid gregor1.UID, convs []types.RemoteConversation, ...) ([]chat1.ConversationLocal, chan types.AsyncInboxResult, error)
- func (s *HybridInboxSource) MembershipUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res types.MembershipUpdateRes, err error)
- func (s *HybridInboxSource) NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (err error)
- func (s *HybridInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) Read(ctx context.Context, uid gregor1.UID, ...) (inbox types.Inbox, localizeCb chan types.AsyncInboxResult, err error)
- func (s *HybridInboxSource) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) ReadUnverified(ctx context.Context, uid gregor1.UID, ...) (res types.Inbox, err error)
- func (b HybridInboxSource) RemoteSetConversationStatus(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) (err error)
- func (b HybridInboxSource) Resume(ctx context.Context) bool
- func (s *HybridInboxSource) Search(ctx context.Context, uid gregor1.UID, query string, limit int) (res []types.RemoteConversation, err error)
- func (s *HybridInboxSource) SetAppNotificationSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) SetConvRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res *chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) SetConvSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res *chat1.ConversationLocal, err error)
- func (b HybridInboxSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
- func (s *HybridInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) SetTeamRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (convs []chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) Start(ctx context.Context, uid gregor1.UID)
- func (s *HybridInboxSource) Stop(ctx context.Context) chan struct{}
- func (s *HybridInboxSource) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (convs []chat1.ConversationLocal, err error)
- func (b HybridInboxSource) Suspend(ctx context.Context) bool
- func (s *HybridInboxSource) TeamTypeChanged(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (convs []chat1.ConversationLocal, err error)
- func (s *HybridInboxSource) UpdateInboxVersion(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers) (err error)
- func (s *HybridInboxSource) UpgradeKBFSToImpteam(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- type IdentifyChangedHandler
- type ImplicitTeamsNameInfoSource
- func (t *ImplicitTeamsNameInfoSource) AllCryptKeys(ctx context.Context, name string, public bool) (res types.AllCryptKeys, err error)
- func (t *ImplicitTeamsNameInfoSource) DecryptionKey(ctx context.Context, name string, teamID chat1.TLFID, ...) (res types.CryptKey, err error)
- func (t *ImplicitTeamsNameInfoSource) EncryptionKey(ctx context.Context, name string, teamID chat1.TLFID, ...) (res types.CryptKey, ni types.NameInfo, err error)
- func (t *ImplicitTeamsNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (teamEK keybase1.TeamEk, err error)
- func (t *ImplicitTeamsNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (teamEK keybase1.TeamEk, err error)
- func (t *ImplicitTeamsNameInfoSource) LookupID(ctx context.Context, name string, public bool) (res types.NameInfo, err error)
- func (t *ImplicitTeamsNameInfoSource) LookupName(ctx context.Context, tlfID chat1.TLFID, public bool) (res types.NameInfo, err error)
- func (t *ImplicitTeamsNameInfoSource) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (bool, []keybase1.KID, error)
- type ImpteamBadteamError
- type InvalidMACError
- type KBFSNameInfoSource
- func (t *KBFSNameInfoSource) AllCryptKeys(ctx context.Context, tlfName string, public bool) (res types.AllCryptKeys, err error)
- func (t *KBFSNameInfoSource) CompleteAndCanonicalizePrivateTlfName(ctx context.Context, tlfName string) (res keybase1.CanonicalTLFNameAndIDWithBreaks, err error)
- func (t *KBFSNameInfoSource) CryptKeys(ctx context.Context, tlfName string) (res keybase1.GetTLFCryptKeysRes, ferr error)
- func (t *KBFSNameInfoSource) DecryptionKey(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (res types.CryptKey, err error)
- func (t *KBFSNameInfoSource) EncryptionKey(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (res types.CryptKey, ni types.NameInfo, err error)
- func (t *KBFSNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (teamEK keybase1.TeamEk, err error)
- func (t *KBFSNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (teamEK keybase1.TeamEk, err error)
- func (t *KBFSNameInfoSource) LookupID(ctx context.Context, tlfName string, public bool) (res types.NameInfo, err error)
- func (t *KBFSNameInfoSource) LookupName(ctx context.Context, tlfID chat1.TLFID, public bool) (res types.NameInfo, err error)
- func (t *KBFSNameInfoSource) PublicCanonicalTLFNameAndID(ctx context.Context, tlfName string) (res keybase1.CanonicalTLFNameAndIDWithBreaks, ferr error)
- func (t *KBFSNameInfoSource) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (bool, []keybase1.KID, error)
- type KeyFinderImpl
- func (k *KeyFinderImpl) EphemeralKeyForDecryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (keybase1.TeamEk, error)
- func (k *KeyFinderImpl) EphemeralKeyForEncryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (ek keybase1.TeamEk, err error)
- func (k *KeyFinderImpl) FindForDecryption(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (res types.CryptKey, err error)
- func (k *KeyFinderImpl) FindForEncryption(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (res types.CryptKey, ni types.NameInfo, err error)
- func (k *KeyFinderImpl) Reset()
- func (k *KeyFinderImpl) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (bool, []keybase1.KID, error)
- type KeyFinderMock
- func (k *KeyFinderMock) EphemeralKeyForDecryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (keybase1.TeamEk, error)
- func (k *KeyFinderMock) EphemeralKeyForEncryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (keybase1.TeamEk, error)
- func (k *KeyFinderMock) FindForDecryption(ctx context.Context, tlfName string, teamID chat1.TLFID, ...) (res types.CryptKey, err error)
- func (k *KeyFinderMock) FindForEncryption(ctx context.Context, tlfName string, teamID chat1.TLFID, ...) (res types.CryptKey, ni types.NameInfo, err error)
- func (k *KeyFinderMock) Reset()
- func (k *KeyFinderMock) SetNameInfoSourceOverride(ni types.NameInfoSource)
- func (k *KeyFinderMock) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (bool, []keybase1.KID, error)
- type MobilePush
- func (h *MobilePush) AckNotificationSuccess(ctx context.Context, pushIDs []string)
- func (h *MobilePush) FormatPushText(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) (res string, err error)
- func (h *MobilePush) UnboxPushNotification(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) (res chat1.MessageUnboxed, err error)
- type NameIdentifier
- type NewConvFindExistingMode
- type NonblockingSender
- func (s *NonblockingSender) Prepare(ctx context.Context, msg chat1.MessagePlaintext, ...) (types.SenderPrepareResult, error)
- func (s *NonblockingSender) Send(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, ...) (chat1.OutboxID, *chat1.MessageBoxed, error)
- func (s *NonblockingSender) SendUnfurlNonblock(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, ...) (chat1.OutboxID, error)
- type NotAuthenticatedForThisDeviceError
- type NotifyRouterActivityRouter
- func (n *NotifyRouterActivityRouter) Activity(ctx context.Context, uid gregor1.UID, topicType chat1.TopicType, ...)
- func (n *NotifyRouterActivityRouter) AttachmentUploadProgress(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) AttachmentUploadStart(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) InboxStale(ctx context.Context, uid gregor1.UID)
- func (n *NotifyRouterActivityRouter) InboxSyncStarted(ctx context.Context, uid gregor1.UID)
- func (n *NotifyRouterActivityRouter) InboxSynced(ctx context.Context, uid gregor1.UID, topicType chat1.TopicType, ...)
- func (n *NotifyRouterActivityRouter) JoinedConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) KBFSToImpteamUpgrade(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) LeftConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) PromptUnfurl(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) ResetConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) SetConvRetention(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) SetConvSettings(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) SetTeamRetention(ctx context.Context, uid gregor1.UID, teamID keybase1.TeamID, ...)
- func (n *NotifyRouterActivityRouter) SubteamRename(ctx context.Context, uid gregor1.UID, convIDs []chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) TLFFinalize(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) TLFResolve(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (n *NotifyRouterActivityRouter) ThreadsStale(ctx context.Context, uid gregor1.UID, updates []chat1.ConversationStaleUpdate)
- func (n *NotifyRouterActivityRouter) TypingUpdate(ctx context.Context, updates []chat1.ConvTypingUpdate)
- type OfflineClient
- func (e OfflineClient) Call(ctx context.Context, method string, arg interface{}, res interface{}) error
- func (e OfflineClient) CallCompressed(ctx context.Context, method string, arg interface{}, res interface{}, ...) error
- func (e OfflineClient) Notify(ctx context.Context, method string, arg interface{}) error
- type OfflineError
- type OfflineErrorKind
- type PermanentUnboxingError
- func (e PermanentUnboxingError) Error() string
- func (e PermanentUnboxingError) ExportType() chat1.MessageUnboxedErrorType
- func (e PermanentUnboxingError) Inner() error
- func (e PermanentUnboxingError) InternalError() string
- func (e PermanentUnboxingError) IsCritical() bool
- func (e PermanentUnboxingError) IsPermanent() bool
- func (e PermanentUnboxingError) ToStatus() (status keybase1.Status)
- func (e PermanentUnboxingError) VersionKind() chat1.VersionKind
- func (e PermanentUnboxingError) VersionNumber() int
- type PublicTeamEphemeralKeyError
- type PushHandler
- func (g *PushHandler) Activity(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) ConversationsUpdate(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) HandleOobm(ctx context.Context, obm gregor.OutOfBandMessage) (bool, error)
- func (g *PushHandler) MembershipUpdate(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) SetBadger(badger *badges.Badger)
- func (g *PushHandler) SetClock(clock clockwork.Clock)
- func (g *PushHandler) SetConvRetention(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) SetConvSettings(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) SetTeamRetention(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) SubteamRename(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) TlfFinalize(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) TlfResolve(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) Typing(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- func (g *PushHandler) UpgradeKBFSToImpteam(ctx context.Context, m gregor.OutOfBandMessage) (err error)
- type RemoteAttachmentFetcher
- func (r *RemoteAttachmentFetcher) DeleteAssets(ctx context.Context, convID chat1.ConversationID, assets []chat1.Asset, ...) (err error)
- func (r *RemoteAttachmentFetcher) FetchAttachment(ctx context.Context, w io.Writer, convID chat1.ConversationID, ...) (err error)
- func (r *RemoteAttachmentFetcher) IsAssetLocal(ctx context.Context, asset chat1.Asset) (bool, error)
- func (r *RemoteAttachmentFetcher) OnDbNuke(mctx libkb.MetaContext) error
- func (r *RemoteAttachmentFetcher) PutUploadedAsset(ctx context.Context, filename string, asset chat1.Asset) error
- func (r *RemoteAttachmentFetcher) StreamAttachment(ctx context.Context, convID chat1.ConversationID, asset chat1.Asset, ...) (res io.ReadSeeker, err error)
- type RemoteClient
- func (c *RemoteClient) Call(ctx context.Context, method string, arg interface{}, res interface{}) (err error)
- func (c *RemoteClient) CallCompressed(ctx context.Context, method string, arg interface{}, res interface{}, ...) (err error)
- func (c *RemoteClient) Notify(ctx context.Context, method string, arg interface{}) (err error)
- type RemoteConversationSource
- func (s *RemoteConversationSource) AcquireConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) error
- func (s *RemoteConversationSource) Clear(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID) error
- func (s *RemoteConversationSource) ClearFromDelete(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) bool
- func (s RemoteConversationSource) DeleteAssets(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...)
- func (s *RemoteConversationSource) EphemeralPurge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (*chat1.EphemeralPurgeInfo, []chat1.MessageUnboxed, error)
- func (s *RemoteConversationSource) Expunge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) error
- func (s *RemoteConversationSource) GetMessages(ctx context.Context, conv types.UnboxConversationInfo, uid gregor1.UID, ...) ([]chat1.MessageUnboxed, error)
- func (s *RemoteConversationSource) GetMessagesWithRemotes(ctx context.Context, conv chat1.Conversation, uid gregor1.UID, ...) ([]chat1.MessageUnboxed, error)
- func (s *RemoteConversationSource) GetUnreadline(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (*chat1.MessageID, error)
- func (s RemoteConversationSource) MarkAsRead(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (err error)
- func (s *RemoteConversationSource) Pull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (chat1.ThreadView, error)
- func (s RemoteConversationSource) PullFull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (res chat1.ThreadView, err error)
- func (s *RemoteConversationSource) PullLocalOnly(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (chat1.ThreadView, error)
- func (s *RemoteConversationSource) Push(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (chat1.MessageUnboxed, bool, error)
- func (s *RemoteConversationSource) PushUnboxed(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, ...) (bool, error)
- func (s *RemoteConversationSource) ReleaseConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID)
- func (s RemoteConversationSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
- func (s RemoteConversationSource) Sign(payload []byte) ([]byte, error)
- func (s RemoteConversationSource) TransformSupersedes(ctx context.Context, unboxInfo types.UnboxConversationInfo, uid gregor1.UID, ...) ([]chat1.MessageUnboxed, error)
- type RemoteInboxSource
- func (s *RemoteInboxSource) Clear(ctx context.Context, uid gregor1.UID) error
- func (b RemoteInboxSource) Connected(ctx context.Context)
- func (s *RemoteInboxSource) ConversationsUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) error
- func (b RemoteInboxSource) Disconnected(ctx context.Context)
- func (s *RemoteInboxSource) Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res *chat1.ConversationLocal, err error)
- func (b RemoteInboxSource) GetInboxQueryLocalToRemote(ctx context.Context, lquery *chat1.GetInboxLocalQuery) (rquery *chat1.GetInboxQuery, info types.NameInfo, err error)
- func (b RemoteInboxSource) IsMember(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (bool, error)
- func (b RemoteInboxSource) IsOffline(ctx context.Context) bool
- func (s *RemoteInboxSource) IsTeam(ctx context.Context, uid gregor1.UID, item string) (bool, error)
- func (b RemoteInboxSource) Localize(ctx context.Context, uid gregor1.UID, convs []types.RemoteConversation, ...) ([]chat1.ConversationLocal, chan types.AsyncInboxResult, error)
- func (s *RemoteInboxSource) MembershipUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res types.MembershipUpdateRes, err error)
- func (s *RemoteInboxSource) NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) error
- func (s *RemoteInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (*chat1.ConversationLocal, error)
- func (s *RemoteInboxSource) Read(ctx context.Context, uid gregor1.UID, ...) (types.Inbox, chan types.AsyncInboxResult, error)
- func (s *RemoteInboxSource) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (*chat1.ConversationLocal, error)
- func (s *RemoteInboxSource) ReadUnverified(ctx context.Context, uid gregor1.UID, ...) (types.Inbox, error)
- func (b RemoteInboxSource) RemoteSetConversationStatus(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, ...) (err error)
- func (b RemoteInboxSource) Resume(ctx context.Context) bool
- func (s *RemoteInboxSource) Search(ctx context.Context, uid gregor1.UID, query string, limit int) (res []types.RemoteConversation, err error)
- func (s *RemoteInboxSource) SetAppNotificationSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (*chat1.ConversationLocal, error)
- func (s *RemoteInboxSource) SetConvRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res *chat1.ConversationLocal, err error)
- func (s *RemoteInboxSource) SetConvSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res *chat1.ConversationLocal, err error)
- func (b RemoteInboxSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
- func (s *RemoteInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (*chat1.ConversationLocal, error)
- func (s *RemoteInboxSource) SetTeamRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (res []chat1.ConversationLocal, err error)
- func (b RemoteInboxSource) Start(ctx context.Context, uid gregor1.UID)
- func (b RemoteInboxSource) Stop(ctx context.Context) chan struct{}
- func (s *RemoteInboxSource) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (convs []chat1.ConversationLocal, err error)
- func (b RemoteInboxSource) Suspend(ctx context.Context) bool
- func (s *RemoteInboxSource) TeamTypeChanged(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- func (s *RemoteInboxSource) TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) ([]chat1.ConversationLocal, error)
- func (s *RemoteInboxSource) UpdateInboxVersion(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers) error
- func (s *RemoteInboxSource) UpgradeKBFSToImpteam(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, ...) (conv *chat1.ConversationLocal, err error)
- type ReplyFiller
- func (f *ReplyFiller) Fill(ctx context.Context, uid gregor1.UID, conv types.UnboxConversationInfo, ...) (res []chat1.MessageUnboxed, err error)
- func (f *ReplyFiller) FillSingle(ctx context.Context, uid gregor1.UID, conv types.UnboxConversationInfo, ...) (res chat1.MessageUnboxed, err error)
- func (f *ReplyFiller) SetLocalOnlyReplyFill(enabled bool)
- type SenderTestImmediateFailError
- type Server
- func (h *Server) AddTeamMemberAfterReset(ctx context.Context, arg chat1.AddTeamMemberAfterResetArg) (err error)
- func (h *Server) BulkAddToConv(ctx context.Context, arg chat1.BulkAddToConvArg) (err error)
- func (h *Server) CancelActiveInboxSearch(ctx context.Context) (err error)
- func (h *Server) CancelActiveSearch(ctx context.Context) (err error)
- func (h *Server) CancelPost(ctx context.Context, outboxID chat1.OutboxID) (err error)
- func (h *Server) DeleteConversationLocal(ctx context.Context, arg chat1.DeleteConversationLocalArg) (res chat1.DeleteConversationLocalRes, err error)
- func (h *Server) DownloadAttachmentLocal(ctx context.Context, arg chat1.DownloadAttachmentLocalArg) (res chat1.DownloadAttachmentLocalRes, err error)
- func (h *Server) DownloadFileAttachmentLocal(ctx context.Context, arg chat1.DownloadFileAttachmentLocalArg) (res chat1.DownloadFileAttachmentLocalRes, err error)
- func (h *Server) FindConversationsLocal(ctx context.Context, arg chat1.FindConversationsLocalArg) (res chat1.FindConversationsLocalRes, err error)
- func (h *Server) GenerateOutboxID(ctx context.Context) (res chat1.OutboxID, err error)
- func (h *Server) GetCachedThread(ctx context.Context, arg chat1.GetCachedThreadArg) (res chat1.GetThreadLocalRes, err error)
- func (h *Server) GetConversationForCLILocal(ctx context.Context, arg chat1.GetConversationForCLILocalQuery) (res chat1.GetConversationForCLILocalRes, err error)
- func (h *Server) GetGlobalAppNotificationSettingsLocal(ctx context.Context) (res chat1.GlobalAppNotificationSettings, err error)
- func (h *Server) GetInboxAndUnboxLocal(ctx context.Context, arg chat1.GetInboxAndUnboxLocalArg) (res chat1.GetInboxAndUnboxLocalRes, err error)
- func (h *Server) GetInboxAndUnboxUILocal(ctx context.Context, arg chat1.GetInboxAndUnboxUILocalArg) (res chat1.GetInboxAndUnboxUILocalRes, err error)
- func (h *Server) GetInboxNonblockLocal(ctx context.Context, arg chat1.GetInboxNonblockLocalArg) (res chat1.NonblockFetchRes, err error)
- func (h *Server) GetInboxSummaryForCLILocal(ctx context.Context, arg chat1.GetInboxSummaryForCLILocalQuery) (res chat1.GetInboxSummaryForCLILocalRes, err error)
- func (h *Server) GetMessagesLocal(ctx context.Context, arg chat1.GetMessagesLocalArg) (res chat1.GetMessagesLocalRes, err error)
- func (h *Server) GetNextAttachmentMessageLocal(ctx context.Context, arg chat1.GetNextAttachmentMessageLocalArg) (res chat1.GetNextAttachmentMessageLocalRes, err error)
- func (h *Server) GetStaticConfig(ctx context.Context) (res chat1.StaticConfig, err error)
- func (h *Server) GetTLFConversationsLocal(ctx context.Context, arg chat1.GetTLFConversationsLocalArg) (res chat1.GetTLFConversationsLocalRes, err error)
- func (h *Server) GetTeamRetentionLocal(ctx context.Context, teamID keybase1.TeamID) (res *chat1.RetentionPolicy, err error)
- func (h *Server) GetThreadLocal(ctx context.Context, arg chat1.GetThreadLocalArg) (res chat1.GetThreadLocalRes, err error)
- func (h *Server) GetThreadNonblock(ctx context.Context, arg chat1.GetThreadNonblockArg) (res chat1.NonblockFetchRes, fullErr error)
- func (h *Server) GetUnfurlSettings(ctx context.Context) (res chat1.UnfurlSettingsDisplay, err error)
- func (h *Server) GetUnreadline(ctx context.Context, arg chat1.GetUnreadlineArg) (res chat1.UnreadlineRes, err error)
- func (h *Server) GetUploadTempFile(ctx context.Context, arg chat1.GetUploadTempFileArg) (res string, err error)
- func (h *Server) JoinConversationByIDLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)
- func (h *Server) JoinConversationLocal(ctx context.Context, arg chat1.JoinConversationLocalArg) (res chat1.JoinLeaveConversationLocalRes, err error)
- func (h *Server) LeaveConversationLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)
- func (h *Server) LoadFlip(ctx context.Context, arg chat1.LoadFlipArg) (res chat1.LoadFlipRes, err error)
- func (h *Server) LoadGallery(ctx context.Context, arg chat1.LoadGalleryArg) (res chat1.LoadGalleryRes, err error)
- func (h *Server) MakePreview(ctx context.Context, arg chat1.MakePreviewArg) (res chat1.MakePreviewRes, err error)
- func (h *Server) MakeUploadTempFile(ctx context.Context, arg chat1.MakeUploadTempFileArg) (res string, err error)
- func (h *Server) MarkAsReadLocal(ctx context.Context, arg chat1.MarkAsReadLocalArg) (res chat1.MarkAsReadLocalRes, err error)
- func (h *Server) NewConversationLocal(ctx context.Context, arg chat1.NewConversationLocalArg) (res chat1.NewConversationLocalRes, err error)
- func (h *Server) PostDeleteHistoryByAge(ctx context.Context, arg chat1.PostDeleteHistoryByAgeArg) (res chat1.PostLocalRes, err error)
- func (h *Server) PostDeleteHistoryThrough(ctx context.Context, arg chat1.PostDeleteHistoryThroughArg) (res chat1.PostLocalRes, err error)
- func (h *Server) PostDeleteHistoryUpto(ctx context.Context, arg chat1.PostDeleteHistoryUptoArg) (res chat1.PostLocalRes, err error)
- func (h *Server) PostDeleteNonblock(ctx context.Context, arg chat1.PostDeleteNonblockArg) (chat1.PostLocalNonblockRes, error)
- func (h *Server) PostEditNonblock(ctx context.Context, arg chat1.PostEditNonblockArg) (res chat1.PostLocalNonblockRes, err error)
- func (h *Server) PostFileAttachmentLocal(ctx context.Context, arg chat1.PostFileAttachmentLocalArg) (res chat1.PostLocalRes, err error)
- func (h *Server) PostFileAttachmentLocalNonblock(ctx context.Context, arg chat1.PostFileAttachmentLocalNonblockArg) (res chat1.PostLocalNonblockRes, err error)
- func (h *Server) PostHeadline(ctx context.Context, arg chat1.PostHeadlineArg) (chat1.PostLocalRes, error)
- func (h *Server) PostHeadlineNonblock(ctx context.Context, arg chat1.PostHeadlineNonblockArg) (chat1.PostLocalNonblockRes, error)
- func (h *Server) PostLocal(ctx context.Context, arg chat1.PostLocalArg) (res chat1.PostLocalRes, err error)
- func (h *Server) PostLocalNonblock(ctx context.Context, arg chat1.PostLocalNonblockArg) (res chat1.PostLocalNonblockRes, err error)
- func (h *Server) PostMetadata(ctx context.Context, arg chat1.PostMetadataArg) (chat1.PostLocalRes, error)
- func (h *Server) PostMetadataNonblock(ctx context.Context, arg chat1.PostMetadataNonblockArg) (chat1.PostLocalNonblockRes, error)
- func (h *Server) PostReactionNonblock(ctx context.Context, arg chat1.PostReactionNonblockArg) (res chat1.PostLocalNonblockRes, err error)
- func (h *Server) PostTextNonblock(ctx context.Context, arg chat1.PostTextNonblockArg) (res chat1.PostLocalNonblockRes, err error)
- func (h *Server) PreviewConversationByIDLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)
- func (h *Server) ProfileChatSearch(ctx context.Context, identifyBehavior keybase1.TLFIdentifyBehavior) (res map[string]chat1.ProfileSearchConvStats, err error)
- func (h *Server) PutReacjiSkinTone(ctx context.Context, skinTone keybase1.ReacjiSkinTone) (res keybase1.UserReacjis, err error)
- func (h *Server) ResolveMaybeMention(ctx context.Context, mention chat1.MaybeMention) (err error)
- func (h *Server) ResolveUnfurlPrompt(ctx context.Context, arg chat1.ResolveUnfurlPromptArg) (err error)
- func (h *Server) RetryPost(ctx context.Context, arg chat1.RetryPostArg) (err error)
- func (h *Server) SaveUnfurlSettings(ctx context.Context, arg chat1.SaveUnfurlSettingsArg) (err error)
- func (h *Server) SearchInbox(ctx context.Context, arg chat1.SearchInboxArg) (res chat1.SearchInboxRes, err error)
- func (h *Server) SearchRegexp(ctx context.Context, arg chat1.SearchRegexpArg) (res chat1.SearchRegexpRes, err error)
- func (h *Server) SetAppNotificationSettingsLocal(ctx context.Context, arg chat1.SetAppNotificationSettingsLocalArg) (res chat1.SetAppNotificationSettingsLocalRes, err error)
- func (h *Server) SetClock(clock clockwork.Clock)
- func (h *Server) SetConvMinWriterRoleLocal(ctx context.Context, arg chat1.SetConvMinWriterRoleLocalArg) (err error)
- func (h *Server) SetConvRetentionLocal(ctx context.Context, arg chat1.SetConvRetentionLocalArg) (err error)
- func (h *Server) SetConversationStatusLocal(ctx context.Context, arg chat1.SetConversationStatusLocalArg) (res chat1.SetConversationStatusLocalRes, err error)
- func (h *Server) SetGlobalAppNotificationSettingsLocal(ctx context.Context, strSettings map[string]bool) (err error)
- func (h *Server) SetTeamRetentionLocal(ctx context.Context, arg chat1.SetTeamRetentionLocalArg) (err error)
- func (h *Server) ToggleMessageCollapse(ctx context.Context, arg chat1.ToggleMessageCollapseArg) (err error)
- func (h *Server) UnboxMobilePushNotification(ctx context.Context, arg chat1.UnboxMobilePushNotificationArg) (res string, err error)
- func (h *Server) UpdateTyping(ctx context.Context, arg chat1.UpdateTypingArg) (err error)
- func (h *Server) UpdateUnsentText(ctx context.Context, arg chat1.UpdateUnsentTextArg) (err error)
- func (h *Server) UpgradeKBFSConversationToImpteam(ctx context.Context, convID chat1.ConversationID) (err error)
- type ServerConnection
- type SimpleIdentifyNotifier
- type Syncer
- func (s *Syncer) Connected(ctx context.Context, cli chat1.RemoteInterface, uid gregor1.UID, ...) (err error)
- func (s *Syncer) Disconnected(ctx context.Context)
- func (s *Syncer) GetSelectedConversation() chat1.ConversationID
- func (s *Syncer) IsConnected(ctx context.Context) bool
- func (s *Syncer) RegisterOfflinable(offlinable types.Offlinable)
- func (s *Syncer) SelectConversation(ctx context.Context, convID chat1.ConversationID)
- func (s *Syncer) SendChatStaleNotifications(ctx context.Context, uid gregor1.UID, updates []chat1.ConversationStaleUpdate, ...)
- func (s *Syncer) SetClock(clock clockwork.Clock)
- func (s *Syncer) Shutdown()
- func (s *Syncer) Sync(ctx context.Context, cli chat1.RemoteInterface, uid gregor1.UID, ...) (err error)
- type TeamChannelSource
- func (c *TeamChannelSource) GetChannelTopicName(ctx context.Context, uid gregor1.UID, tlfID chat1.TLFID, ...) (res string, err error)
- func (c *TeamChannelSource) GetChannelsFull(ctx context.Context, uid gregor1.UID, tlfID chat1.TLFID, ...) (res []chat1.ConversationLocal, err error)
- func (c *TeamChannelSource) GetChannelsTopicName(ctx context.Context, uid gregor1.UID, tlfID chat1.TLFID, ...) (res []chat1.ChannelNameMention, err error)
- type TeamLoader
- type TeamMentionLoader
- func (l *TeamMentionLoader) IsTeamMention(ctx context.Context, uid gregor1.UID, maybeMention chat1.MaybeMention, ...) bool
- func (l *TeamMentionLoader) LoadTeamMention(ctx context.Context, uid gregor1.UID, maybeMention chat1.MaybeMention, ...) (err error)
- func (l *TeamMentionLoader) Start(ctx context.Context, uid gregor1.UID)
- func (l *TeamMentionLoader) Stop(ctx context.Context) chan struct{}
- type TeamsNameInfoSource
- func (t *TeamsNameInfoSource) AllCryptKeys(ctx context.Context, name string, public bool) (res types.AllCryptKeys, err error)
- func (t *TeamsNameInfoSource) DecryptionKey(ctx context.Context, name string, teamID chat1.TLFID, ...) (res types.CryptKey, err error)
- func (t *TeamsNameInfoSource) EncryptionKey(ctx context.Context, name string, teamID chat1.TLFID, ...) (res types.CryptKey, ni types.NameInfo, err error)
- func (t *TeamsNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (teamEK keybase1.TeamEk, err error)
- func (t *TeamsNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, ...) (teamEK keybase1.TeamEk, err error)
- func (t *TeamsNameInfoSource) LookupID(ctx context.Context, name string, public bool) (res types.NameInfo, err error)
- func (t *TeamsNameInfoSource) LookupName(ctx context.Context, tlfID chat1.TLFID, public bool) (res types.NameInfo, err error)
- func (t *TeamsNameInfoSource) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID, ...) (bool, []keybase1.KID, error)
- type TransientUnboxingError
- func (e TransientUnboxingError) Error() string
- func (e TransientUnboxingError) ExportType() chat1.MessageUnboxedErrorType
- func (e TransientUnboxingError) Inner() error
- func (e TransientUnboxingError) InternalError() string
- func (e TransientUnboxingError) IsCritical() bool
- func (e TransientUnboxingError) IsPermanent() bool
- func (e TransientUnboxingError) ToStatus() (status keybase1.Status)
- func (e TransientUnboxingError) VersionKind() chat1.VersionKind
- func (e TransientUnboxingError) VersionNumber() int
- type TypingMonitor
- type UISource
- type UnknownTLFNameError
- type VersionError
Constants ¶
const CurrentMessageBoxedVersion = chat1.MessageBoxedVersion_V2
Variables ¶
var ErrChatServerTimeout = errors.New("timeout calling chat server")
var ErrDuplicateConnection = errors.New("error calling chat server")
var ErrKeyServerTimeout = errors.New("timeout calling into key server")
Functions ¶
func CreateNameInfoSource ¶
func CreateNameInfoSource(ctx context.Context, g *globals.Context, membersType chat1.ConversationMembersType) types.NameInfoSource
func FindConversations ¶ added in v1.0.27
func FindConversations(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, dataSource types.InboxSourceDataSourceTyp, ri func() chat1.RemoteInterface, uid gregor1.UID, tlfName string, topicType chat1.TopicType, membersTypeIn chat1.ConversationMembersType, vis keybase1.TLFVisibility, topicName string, oneChatPerTLF *bool) (res []chat1.ConversationLocal, err error)
func GetInboxQueryNameInfo ¶ added in v1.0.27
func GetMessage ¶
func GetMessages ¶
func GetTopicNameState ¶ added in v1.0.27
func GetTopicNameState(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, convs []chat1.ConversationLocal, uid gregor1.UID, tlfID chat1.TLFID, topicType chat1.TopicType, membersType chat1.ConversationMembersType) (res chat1.TopicNameState, err error)
func IsRekeyError ¶
func IsRekeyError(err error) (typ chat1.ConversationErrorType, ok bool)
func JoinConversation ¶ added in v1.0.27
func JoinConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ri func() chat1.RemoteInterface, uid gregor1.UID, convID chat1.ConversationID) (err error)
func JoinConversationByName ¶
func LeaveConversation ¶ added in v1.0.27
func LeaveConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ri func() chat1.RemoteInterface, uid gregor1.UID, convID chat1.ConversationID) (err error)
func LocalOnlyReplyFill ¶
func LocalOnlyReplyFill(enabled bool) func(*ReplyFiller)
func NewConversation ¶ added in v1.0.27
func NewConversation(ctx context.Context, g *globals.Context, uid gregor1.UID, tlfName string, topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType, vis keybase1.TLFVisibility, ri func() chat1.RemoteInterface, findExistingMode NewConvFindExistingMode) (chat1.ConversationLocal, error)
func NewConversationSource ¶
func NewConversationSource(g *globals.Context, typ string, boxer *Boxer, storage *storage.Storage, ri func() chat1.RemoteInterface) types.ConversationSource
func NewConversationWithMemberSourceConv ¶
func NewConversationWithMemberSourceConv(ctx context.Context, g *globals.Context, uid gregor1.UID, tlfName string, topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType, vis keybase1.TLFVisibility, ri func() chat1.RemoteInterface, findExistingMode NewConvFindExistingMode, memberSourceConv *chat1.ConversationID) (chat1.ConversationLocal, error)
func NewCtxFactory ¶
func NewCtxFactory(g *globals.Context) types.ContextFactory
func NewFTLError ¶
func NewInboxSource ¶ added in v1.0.19
func NewInboxSource(g *globals.Context, typ string, badger *badges.Badger, ri func() chat1.RemoteInterface) types.InboxSource
func NewKeyFinder ¶
NewKeyFinder creates a KeyFinder.
func NewPermanentUnboxingError ¶ added in v1.0.19
func NewPermanentUnboxingError(inner error) types.UnboxingError
func NewTransientUnboxingError ¶ added in v1.0.19
func NewTransientUnboxingError(inner error) types.UnboxingError
func PresentConversationLocalWithFetchRetry ¶
func PresentConversationLocalWithFetchRetry(ctx context.Context, g *globals.Context, uid gregor1.UID, conv chat1.ConversationLocal) (res *chat1.InboxUIItem)
func PreviewConversation ¶ added in v1.0.34
func PreviewConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler, ri func() chat1.RemoteInterface, uid gregor1.UID, convID chat1.ConversationID) (err error)
func RecentConversationParticipants ¶ added in v1.0.27
Types ¶
type AttachmentHTTPSrv ¶ added in v1.0.48
type AttachmentHTTPSrv struct { sync.Mutex globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewAttachmentHTTPSrv ¶ added in v1.0.48
func NewAttachmentHTTPSrv(g *globals.Context, fetcher types.AttachmentFetcher, ri func() chat1.RemoteInterface) *AttachmentHTTPSrv
func (*AttachmentHTTPSrv) GetAttachmentFetcher ¶ added in v1.0.48
func (r *AttachmentHTTPSrv) GetAttachmentFetcher() types.AttachmentFetcher
func (*AttachmentHTTPSrv) GetGiphyGalleryURL ¶
func (r *AttachmentHTTPSrv) GetGiphyGalleryURL(ctx context.Context, convID chat1.ConversationID, tlfName string, results []chat1.GiphySearchResult) string
func (*AttachmentHTTPSrv) GetGiphyURL ¶
func (r *AttachmentHTTPSrv) GetGiphyURL(ctx context.Context, giphyURL string) string
func (*AttachmentHTTPSrv) GetPendingPreviewURL ¶
func (*AttachmentHTTPSrv) GetURL ¶ added in v1.0.48
func (r *AttachmentHTTPSrv) GetURL(ctx context.Context, convID chat1.ConversationID, msgID chat1.MessageID, preview bool) string
func (*AttachmentHTTPSrv) GetUnfurlAssetURL ¶
func (r *AttachmentHTTPSrv) GetUnfurlAssetURL(ctx context.Context, convID chat1.ConversationID, asset chat1.Asset) string
func (*AttachmentHTTPSrv) OnDbNuke ¶
func (r *AttachmentHTTPSrv) OnDbNuke(mctx libkb.MetaContext) error
type AttachmentUploadError ¶
func NewAttachmentUploadError ¶
func NewAttachmentUploadError(msg string, perm bool) AttachmentUploadError
func (AttachmentUploadError) Error ¶
func (e AttachmentUploadError) Error() string
func (AttachmentUploadError) IsImmediateFail ¶
func (e AttachmentUploadError) IsImmediateFail() (chat1.OutboxErrorType, bool)
type BackgroundConvLoader ¶ added in v1.0.27
type BackgroundConvLoader struct { globals.Contextified utils.DebugLabeler sync.Mutex // contains filtered or unexported fields }
func NewBackgroundConvLoader ¶ added in v1.0.27
func NewBackgroundConvLoader(g *globals.Context) *BackgroundConvLoader
func (*BackgroundConvLoader) Queue ¶ added in v1.0.27
func (b *BackgroundConvLoader) Queue(ctx context.Context, job types.ConvLoaderJob) error
func (*BackgroundConvLoader) Resume ¶ added in v1.0.46
func (b *BackgroundConvLoader) Resume(ctx context.Context) bool
func (*BackgroundConvLoader) Start ¶ added in v1.0.27
func (b *BackgroundConvLoader) Start(ctx context.Context, uid gregor1.UID)
func (*BackgroundConvLoader) Stop ¶ added in v1.0.27
func (b *BackgroundConvLoader) Stop(ctx context.Context) chan struct{}
type BackgroundEphemeralPurger ¶
type BackgroundEphemeralPurger struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewBackgroundEphemeralPurger ¶
func NewBackgroundEphemeralPurger(g *globals.Context, storage *storage.Storage) *BackgroundEphemeralPurger
func (*BackgroundEphemeralPurger) Queue ¶
func (b *BackgroundEphemeralPurger) Queue(ctx context.Context, purgeInfo chat1.EphemeralPurgeInfo) error
func (*BackgroundEphemeralPurger) SetClock ¶
func (b *BackgroundEphemeralPurger) SetClock(clock clockwork.Clock)
func (*BackgroundEphemeralPurger) Start ¶
func (b *BackgroundEphemeralPurger) Start(ctx context.Context, uid gregor1.UID)
func (*BackgroundEphemeralPurger) Stop ¶
func (b *BackgroundEphemeralPurger) Stop(ctx context.Context) (ch chan struct{})
type BlockingSender ¶ added in v1.0.19
type BlockingSender struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewBlockingSender ¶ added in v1.0.19
func NewBlockingSender(g *globals.Context, boxer *Boxer, getRi func() chat1.RemoteInterface) *BlockingSender
func (*BlockingSender) Prepare ¶ added in v1.0.19
func (s *BlockingSender) Prepare(ctx context.Context, plaintext chat1.MessagePlaintext, membersType chat1.ConversationMembersType, conv *chat1.ConversationLocal, inopts *chat1.SenderPrepareOptions) (res types.SenderPrepareResult, err error)
Prepare a message to be sent. Returns (boxedMessage, pendingAssetDeletes, error)
func (*BlockingSender) Send ¶ added in v1.0.19
func (s *BlockingSender) Send(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, clientPrev chat1.MessageID, outboxID *chat1.OutboxID, sendOpts *chat1.SenderSendOptions, prepareOpts *chat1.SenderPrepareOptions) (obid chat1.OutboxID, boxed *chat1.MessageBoxed, err error)
func (*BlockingSender) SetClock ¶
func (s *BlockingSender) SetClock(clock clockwork.Clock)
type BodyHashInvalid ¶ added in v1.0.19
type BodyHashInvalid struct{}
func (BodyHashInvalid) Error ¶ added in v1.0.19
func (e BodyHashInvalid) Error() string
type Boxer ¶
type Boxer struct { utils.DebugLabeler globals.Contextified // contains filtered or unexported fields }
func (*Boxer) BoxMessage ¶
func (b *Boxer) BoxMessage(ctx context.Context, msg chat1.MessagePlaintext, membersType chat1.ConversationMembersType, signingKeyPair libkb.NaclSigningKeyPair, info *types.BoxerEncryptionInfo) (res chat1.MessageBoxed, err error)
BoxMessage encrypts a keybase1.MessagePlaintext into a chat1.MessageBoxed. It finds the most recent key for the TLF.
func (*Boxer) CompareTlfNames ¶ added in v1.0.21
func (*Boxer) GetBoxedVersion ¶
func (b *Boxer) GetBoxedVersion(msg chat1.MessagePlaintext) (chat1.MessageBoxedVersion, error)
func (*Boxer) GetEncryptionInfo ¶
func (b *Boxer) GetEncryptionInfo(ctx context.Context, msg *chat1.MessagePlaintext, membersType chat1.ConversationMembersType, signingKeyPair libkb.NaclSigningKeyPair) (res types.BoxerEncryptionInfo, err error)
func (*Boxer) UnboxMessage ¶
func (b *Boxer) UnboxMessage(ctx context.Context, boxed chat1.MessageBoxed, conv types.UnboxConversationInfo, info *types.BoxerEncryptionInfo) (m chat1.MessageUnboxed, uberr types.UnboxingError)
UnboxMessage unboxes a chat1.MessageBoxed into a chat1.MessageUnboxed. It finds the appropriate keybase1.CryptKey, decrypts the message, and verifies several things:
- The message's signature is valid.
- (TODO) The signing KID was valid when the signature was made.
- (TODO) The signing KID belongs to the sending device.
- (TODO) The sending device belongs to the sender. [Note that we do currently check the KID -> UID relationship, independent of the device ID.]
- (TODO) The sender has write permission in the TLF.
- (TODO) The TLF name, public flag, and finalized info resolve to the TLF ID.
- The conversation ID derives from the ConversationIDTriple.
- The body hash is not a replay from another message we know about.
- The prev pointers are consistent with other messages we know about.
- (TODO) The prev pointers are not absurdly ancient.
- The ClientHeader provided with the BoxedMessage matches the one we decrypt.
The first return value is unusable if the err != nil. Returns (_, err) for non-permanent errors, and (MessageUnboxedError, nil) for permanent errors. Permanent errors can be cached and must be treated as a value to deal with, whereas temporary errors are transient failures.
func (*Boxer) UnboxMessages ¶
func (b *Boxer) UnboxMessages(ctx context.Context, boxed []chat1.MessageBoxed, conv types.UnboxConversationInfo) (unboxed []chat1.MessageUnboxed, err error)
func (*Boxer) UnboxThread ¶
func (b *Boxer) UnboxThread(ctx context.Context, boxed chat1.ThreadViewBoxed, conv types.UnboxConversationInfo) (thread chat1.ThreadView, err error)
unboxThread transforms a chat1.ThreadViewBoxed to a keybase1.ThreadView.
func (*Boxer) ValidSenderKey ¶ added in v1.0.19
func (b *Boxer) ValidSenderKey(ctx context.Context, sender gregor1.UID, key []byte, ctime gregor1.Time) (found, validAtCTime bool, revoked *gregor1.Time, unboxErr types.UnboxingError)
ValidSenderKey checks that the key was active for sender at ctime. This trusts the server for ctime, so a colluding server could use a revoked key and this check erroneously pass. But (revoked != nil) if the key was ever revoked, so that is irrespective of ctime. Returns (validAtCtime, revoked, err)
type BoxingCryptKeysError ¶ added in v1.0.19
type BoxingCryptKeysError struct {
Err error
}
func NewBoxingCryptKeysError ¶ added in v1.0.19
func NewBoxingCryptKeysError(err error) BoxingCryptKeysError
func (BoxingCryptKeysError) Cause ¶
func (e BoxingCryptKeysError) Cause() error
Cause implements the pkg/errors Cause() method, also cloned in libkb via HumanError, so that we know which error to show to the human being using keybase (rather than for our own internal uses).
func (BoxingCryptKeysError) Error ¶ added in v1.0.19
func (e BoxingCryptKeysError) Error() string
func (BoxingCryptKeysError) Inner ¶ added in v1.0.19
func (e BoxingCryptKeysError) Inner() error
func (BoxingCryptKeysError) IsImmediateFail ¶ added in v1.0.19
func (e BoxingCryptKeysError) IsImmediateFail() (chat1.OutboxErrorType, bool)
type BoxingError ¶ added in v1.0.19
func NewBoxingError ¶ added in v1.0.19
func NewBoxingError(msg string, perm bool) BoxingError
func (BoxingError) Error ¶ added in v1.0.19
func (e BoxingError) Error() string
func (BoxingError) IsImmediateFail ¶ added in v1.0.19
func (e BoxingError) IsImmediateFail() (chat1.OutboxErrorType, bool)
type CachingAttachmentFetcher ¶ added in v1.0.48
type CachingAttachmentFetcher struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewCachingAttachmentFetcher ¶ added in v1.0.48
func NewCachingAttachmentFetcher(g *globals.Context, store attachments.Store, size int) *CachingAttachmentFetcher
func (*CachingAttachmentFetcher) DeleteAssets ¶
func (c *CachingAttachmentFetcher) DeleteAssets(ctx context.Context, convID chat1.ConversationID, assets []chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (err error)
func (*CachingAttachmentFetcher) FetchAttachment ¶ added in v1.0.48
func (c *CachingAttachmentFetcher) FetchAttachment(ctx context.Context, w io.Writer, convID chat1.ConversationID, asset chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer, progress types.ProgressReporter) (err error)
func (*CachingAttachmentFetcher) IsAssetLocal ¶
func (*CachingAttachmentFetcher) OnDbNuke ¶
func (c *CachingAttachmentFetcher) OnDbNuke(mctx libkb.MetaContext) error
func (*CachingAttachmentFetcher) PutUploadedAsset ¶
func (*CachingAttachmentFetcher) StreamAttachment ¶
func (c *CachingAttachmentFetcher) StreamAttachment(ctx context.Context, convID chat1.ConversationID, asset chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (res io.ReadSeeker, err error)
type CachingIdentifyNotifier ¶ added in v1.0.42
type CachingIdentifyNotifier struct { globals.Contextified utils.DebugLabeler sync.RWMutex // contains filtered or unexported fields }
func NewCachingIdentifyNotifier ¶ added in v1.0.42
func NewCachingIdentifyNotifier(g *globals.Context) *CachingIdentifyNotifier
func (*CachingIdentifyNotifier) Reset ¶ added in v1.0.42
func (i *CachingIdentifyNotifier) Reset()
func (*CachingIdentifyNotifier) ResetOnGUIConnect ¶ added in v1.0.42
func (i *CachingIdentifyNotifier) ResetOnGUIConnect()
func (*CachingIdentifyNotifier) Send ¶ added in v1.0.42
func (i *CachingIdentifyNotifier) Send(ctx context.Context, update keybase1.CanonicalTLFNameAndIDWithBreaks)
type CachingUPAKFinder ¶ added in v1.0.42
type CachingUPAKFinder struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewCachingUPAKFinder ¶ added in v1.0.42
func NewCachingUPAKFinder(g *globals.Context) *CachingUPAKFinder
func (*CachingUPAKFinder) CheckKIDForUID ¶ added in v1.0.42
func (*CachingUPAKFinder) LookupUsernameAndDevice ¶ added in v1.0.42
type ChatThreadConsistencyError ¶ added in v1.0.19
type ChatThreadConsistencyError interface { error Code() ConsistencyErrorCode }
func CheckPrevPointersAndGetUnpreved ¶
func CheckPrevPointersAndGetUnpreved(thread *chat1.ThreadView) (newPrevsForRegular, newPrevsForExploding []chat1.MessagePreviousPointer, err ChatThreadConsistencyError)
Ingest a ThreadView, check several invariants, and produce a list of prev pointers to not-yet-pointed-to messages. Check several invariants at the same time: 1. No two messages have the same ID. 2. All prev pointers point to messages with lesser IDs. 3. All prev pointers to a message agree on that message's header hash. 4. For all messages we have locally, the hashes pointing to them are actually correct. TODO: All of this should happen in the cache instead of here all at once.
func NewChatThreadConsistencyError ¶ added in v1.0.19
func NewChatThreadConsistencyError(code ConsistencyErrorCode, msg string, formatArgs ...interface{}) ChatThreadConsistencyError
type ConsistencyErrorCode ¶ added in v1.0.19
type ConsistencyErrorCode int
const ( DuplicateID ConsistencyErrorCode = iota OutOfOrderID InconsistentHash IncorrectHash )
type ConversationRetry ¶ added in v1.0.27
type ConversationRetry struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewConversationRetry ¶ added in v1.0.27
func NewConversationRetry(g *globals.Context, convID chat1.ConversationID, tlfID *chat1.TLFID, kind FetchType) *ConversationRetry
func (*ConversationRetry) RekeyFixable ¶ added in v1.0.31
func (*ConversationRetry) SendStale ¶ added in v1.0.27
func (c *ConversationRetry) SendStale(ctx context.Context, uid gregor1.UID)
func (*ConversationRetry) String ¶ added in v1.0.27
func (c *ConversationRetry) String() string
type CtxFactory ¶
type CtxFactory struct {
globals.Contextified
}
func (*CtxFactory) NewKeyFinder ¶
func (c *CtxFactory) NewKeyFinder() types.KeyFinder
func (*CtxFactory) NewUPAKFinder ¶
func (c *CtxFactory) NewUPAKFinder() types.UPAKFinder
type DecryptionKeyNotFoundError ¶
type DecryptionKeyNotFoundError struct {
// contains filtered or unexported fields
}
func NewDecryptionKeyNotFoundError ¶
func NewDecryptionKeyNotFoundError(generation int, public, kbfsEncrypted bool) DecryptionKeyNotFoundError
func (DecryptionKeyNotFoundError) Error ¶
func (e DecryptionKeyNotFoundError) Error() string
type Deliverer ¶ added in v1.0.19
type Deliverer struct { globals.Contextified sync.Mutex utils.DebugLabeler // contains filtered or unexported fields }
func NewDeliverer ¶ added in v1.0.19
func (*Deliverer) ActiveDeliveries ¶
func (*Deliverer) Disconnected ¶ added in v1.0.19
func (*Deliverer) ForceDeliverLoop ¶ added in v1.0.19
func (*Deliverer) IsDelivering ¶
func (*Deliverer) NextFailure ¶
func (s *Deliverer) NextFailure() (chan []chat1.OutboxRecord, func())
func (*Deliverer) Queue ¶ added in v1.0.19
func (s *Deliverer) Queue(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, outboxID *chat1.OutboxID, sendOpts *chat1.SenderSendOptions, prepareOpts *chat1.SenderPrepareOptions, identifyBehavior keybase1.TLFIdentifyBehavior) (obr chat1.OutboxRecord, err error)
type DelivererInfoError ¶ added in v1.0.19
type DelivererInfoError interface {
IsImmediateFail() (chat1.OutboxErrorType, bool)
}
type DevConversationBackedStorage ¶
type DevConversationBackedStorage struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewDevConversationBackedStorage ¶
func NewDevConversationBackedStorage(g *globals.Context, ri func() chat1.RemoteInterface) *DevConversationBackedStorage
type DummyIdentifyNotifier ¶ added in v1.0.42
type DummyIdentifyNotifier struct{}
func (DummyIdentifyNotifier) Reset ¶ added in v1.0.42
func (d DummyIdentifyNotifier) Reset()
func (DummyIdentifyNotifier) ResetOnGUIConnect ¶ added in v1.0.42
func (d DummyIdentifyNotifier) ResetOnGUIConnect()
func (DummyIdentifyNotifier) Send ¶ added in v1.0.42
func (d DummyIdentifyNotifier) Send(ctx context.Context, update keybase1.CanonicalTLFNameAndIDWithBreaks)
type DuplicateTopicNameError ¶ added in v1.0.27
type DuplicateTopicNameError struct {
TopicName string
}
func (DuplicateTopicNameError) Error ¶ added in v1.0.27
func (e DuplicateTopicNameError) Error() string
type EphemeralAlreadyExpiredError ¶
type EphemeralAlreadyExpiredError struct {
// contains filtered or unexported fields
}
func NewEphemeralAlreadyExpiredError ¶
func NewEphemeralAlreadyExpiredError() EphemeralAlreadyExpiredError
func (EphemeralAlreadyExpiredError) Error ¶
func (e EphemeralAlreadyExpiredError) Error() string
func (EphemeralAlreadyExpiredError) InternalError ¶
func (e EphemeralAlreadyExpiredError) InternalError() string
type EphemeralUnboxingError ¶
type EphemeralUnboxingError struct {
// contains filtered or unexported fields
}
func NewEphemeralUnboxingError ¶
func NewEphemeralUnboxingError(inner ephemeral.EphemeralKeyError) EphemeralUnboxingError
func (EphemeralUnboxingError) Error ¶
func (e EphemeralUnboxingError) Error() string
func (EphemeralUnboxingError) InternalError ¶
func (e EphemeralUnboxingError) InternalError() string
type FetchRetrier ¶ added in v1.0.22
type FetchRetrier struct { globals.Contextified utils.DebugLabeler sync.Mutex // contains filtered or unexported fields }
FetchRetrier is responsible for tracking any nonblock fetch failures, and retrying them automatically.
func NewFetchRetrier ¶ added in v1.0.22
func NewFetchRetrier(g *globals.Context) *FetchRetrier
func (*FetchRetrier) Connected ¶ added in v1.0.22
func (f *FetchRetrier) Connected(ctx context.Context)
Connected is called when a connection to the chat server is established, and forces a pass over the retry queue
func (*FetchRetrier) Disconnected ¶ added in v1.0.22
func (f *FetchRetrier) Disconnected(ctx context.Context)
Disconnected is called when we lose connection to the chat server, and pauses attempts on the retry queue.
func (*FetchRetrier) Failure ¶ added in v1.0.22
func (f *FetchRetrier) Failure(ctx context.Context, uid gregor1.UID, desc types.RetryDescription) (err error)
Failure indicates a failure of type kind has happened when loading a conversation.
func (*FetchRetrier) Force ¶ added in v1.0.22
func (f *FetchRetrier) Force(ctx context.Context)
Force forces a run of the retry loop.
func (*FetchRetrier) IsOffline ¶ added in v1.0.22
func (f *FetchRetrier) IsOffline(ctx context.Context) bool
IsOffline returns if the module thinks we are connected to the chat server.
func (*FetchRetrier) Rekey ¶ added in v1.0.31
func (f *FetchRetrier) Rekey(ctx context.Context, name string, membersType chat1.ConversationMembersType, public bool)
func (*FetchRetrier) SetClock ¶ added in v1.0.22
func (f *FetchRetrier) SetClock(clock clockwork.Clock)
SetClock sets a custom clock for testing.
func (*FetchRetrier) Start ¶ added in v1.0.22
func (f *FetchRetrier) Start(ctx context.Context, uid gregor1.UID)
func (*FetchRetrier) Stop ¶ added in v1.0.22
func (f *FetchRetrier) Stop(ctx context.Context) chan struct{}
func (*FetchRetrier) Success ¶ added in v1.0.22
func (f *FetchRetrier) Success(ctx context.Context, uid gregor1.UID, desc types.RetryDescription) (err error)
Success indicates a success of type kind loading a conversation. This effectively removes that conversation from the retry queue.
type FlipManager ¶
type FlipManager struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewFlipManager ¶
func NewFlipManager(g *globals.Context, ri func() chat1.RemoteInterface) *FlipManager
func (*FlipManager) CLogf ¶
func (m *FlipManager) CLogf(ctx context.Context, fmt string, args ...interface{})
CLogf implements the flip.DealersHelper interface
func (*FlipManager) Clock ¶
func (m *FlipManager) Clock() clockwork.Clock
Clock implements the flip.DealersHelper interface
func (*FlipManager) DescribeFlipText ¶
func (m *FlipManager) DescribeFlipText(ctx context.Context, text string) string
func (*FlipManager) HasActiveGames ¶
func (m *FlipManager) HasActiveGames(ctx context.Context) bool
func (*FlipManager) IsFlipConversationCreated ¶
func (m *FlipManager) IsFlipConversationCreated(ctx context.Context, outboxID chat1.OutboxID) (convID chat1.ConversationID, status types.FlipSendStatus)
func (*FlipManager) LoadFlip ¶
func (m *FlipManager) LoadFlip(ctx context.Context, uid gregor1.UID, hostConvID chat1.ConversationID, hostMsgID chat1.MessageID, flipConvID chat1.ConversationID, gameID chat1.FlipGameID) (res chan chat1.UICoinFlipStatus, err chan error)
LoadFlip implements the types.CoinFlipManager interface
func (*FlipManager) MaybeInjectFlipMessage ¶
func (m *FlipManager) MaybeInjectFlipMessage(ctx context.Context, boxedMsg chat1.MessageBoxed, inboxVers chat1.InboxVers, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType) bool
MaybeInjectFlipMessage implements the types.CoinFlipManager interface
func (*FlipManager) Me ¶
func (m *FlipManager) Me() flip.UserDevice
Me implements the flip.DealersHelper interface
func (*FlipManager) SendChat ¶
func (m *FlipManager) SendChat(ctx context.Context, convID chat1.ConversationID, gameID chat1.FlipGameID, msg flip.GameMessageEncoded) (err error)
SendChat implements the flip.DealersHelper interface
func (*FlipManager) ServerTime ¶
ServerTime implements the flip.DealersHelper interface
func (*FlipManager) ShouldCommit ¶
func (m *FlipManager) ShouldCommit(ctx context.Context) bool
func (*FlipManager) StartFlip ¶
func (m *FlipManager) StartFlip(ctx context.Context, uid gregor1.UID, hostConvID chat1.ConversationID, tlfName, text string, inOutboxID *chat1.OutboxID) (err error)
StartFlip implements the types.CoinFlipManager interface
func (*FlipManager) Stop ¶
func (m *FlipManager) Stop(ctx context.Context) (ch chan struct{})
type FlipVisualizer ¶
type FlipVisualizer struct {
// contains filtered or unexported fields
}
func NewFlipVisualizer ¶
func NewFlipVisualizer(width, height int) *FlipVisualizer
func (*FlipVisualizer) Visualize ¶
func (v *FlipVisualizer) Visualize(status *chat1.UICoinFlipStatus)
type FullInboxRetry ¶ added in v1.0.27
type FullInboxRetry struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewFullInboxRetry ¶ added in v1.0.27
func NewFullInboxRetry(g *globals.Context, query *chat1.GetInboxLocalQuery, p *chat1.Pagination) FullInboxRetry
func (FullInboxRetry) RekeyFixable ¶ added in v1.0.31
func (FullInboxRetry) SendStale ¶ added in v1.0.27
func (f FullInboxRetry) SendStale(ctx context.Context, uid gregor1.UID)
func (FullInboxRetry) String ¶ added in v1.0.27
func (f FullInboxRetry) String() string
type HeaderMismatchError ¶ added in v1.0.19
type HeaderMismatchError struct {
Field string
}
func NewHeaderMismatchError ¶ added in v1.0.19
func NewHeaderMismatchError(field string) HeaderMismatchError
func (HeaderMismatchError) Error ¶ added in v1.0.19
func (e HeaderMismatchError) Error() string
type Helper ¶ added in v1.0.34
type Helper struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewHelper ¶ added in v1.0.34
func NewHelper(g *globals.Context, ri func() chat1.RemoteInterface) *Helper
func (*Helper) FindConversations ¶ added in v1.0.40
func (h *Helper) FindConversations(ctx context.Context, name string, topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType, vis keybase1.TLFVisibility) ([]chat1.ConversationLocal, error)
func (*Helper) FindConversationsByID ¶ added in v1.0.40
func (h *Helper) FindConversationsByID(ctx context.Context, convIDs []chat1.ConversationID) ([]chat1.ConversationLocal, error)
func (*Helper) GetChannelTopicName ¶ added in v1.0.42
func (h *Helper) GetChannelTopicName(ctx context.Context, teamID keybase1.TeamID, topicType chat1.TopicType, convID chat1.ConversationID) (topicName string, err error)
GetChannelTopicName gets the name of a team channel even if it's not in the inbox.
func (*Helper) GetMessage ¶
func (h *Helper) GetMessage(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, msgID chat1.MessageID, resolveSupersedes bool, reason *chat1.GetThreadReason) (chat1.MessageUnboxed, error)
func (*Helper) GetMessages ¶ added in v1.0.48
func (h *Helper) GetMessages(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, msgIDs []chat1.MessageID, resolveSupersedes bool, reason *chat1.GetThreadReason) ([]chat1.MessageUnboxed, error)
func (*Helper) JoinConversationByID ¶
func (*Helper) JoinConversationByName ¶
func (*Helper) LeaveConversation ¶
func (*Helper) NewConversation ¶
func (*Helper) NewConversationWithMemberSourceConv ¶
func (h *Helper) NewConversationWithMemberSourceConv(ctx context.Context, uid gregor1.UID, tlfName string, topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType, vis keybase1.TLFVisibility, memberSourceConv *chat1.ConversationID) (chat1.ConversationLocal, error)
func (*Helper) SendMsgByID ¶ added in v1.0.34
func (h *Helper) SendMsgByID(ctx context.Context, convID chat1.ConversationID, tlfName string, body chat1.MessageBody, msgType chat1.MessageType) error
func (*Helper) SendMsgByIDNonblock ¶ added in v1.0.34
func (*Helper) SendMsgByName ¶ added in v1.0.34
func (h *Helper) SendMsgByName(ctx context.Context, name string, topicName *string, membersType chat1.ConversationMembersType, ident keybase1.TLFIdentifyBehavior, body chat1.MessageBody, msgType chat1.MessageType) error
func (*Helper) SendMsgByNameNonblock ¶ added in v1.0.34
func (h *Helper) SendMsgByNameNonblock(ctx context.Context, name string, topicName *string, membersType chat1.ConversationMembersType, ident keybase1.TLFIdentifyBehavior, body chat1.MessageBody, msgType chat1.MessageType, inOutboxID *chat1.OutboxID) (chat1.OutboxID, error)
func (*Helper) SendTextByID ¶ added in v1.0.34
func (*Helper) SendTextByIDNonblock ¶ added in v1.0.34
func (*Helper) SendTextByName ¶ added in v1.0.34
func (*Helper) SendTextByNameNonblock ¶ added in v1.0.34
func (*Helper) UpgradeKBFSToImpteam ¶ added in v1.0.46
func (*Helper) UserReacjis ¶
type HybridConversationSource ¶
type HybridConversationSource struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewHybridConversationSource ¶
func NewHybridConversationSource(g *globals.Context, b *Boxer, storage *storage.Storage, ri func() chat1.RemoteInterface) *HybridConversationSource
func (*HybridConversationSource) AcquireConversationLock ¶ added in v1.0.48
func (s *HybridConversationSource) AcquireConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) error
func (*HybridConversationSource) Clear ¶
func (s *HybridConversationSource) Clear(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID) error
func (*HybridConversationSource) ClearFromDelete ¶ added in v1.0.48
func (s *HybridConversationSource) ClearFromDelete(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, deleteID chat1.MessageID) bool
ClearFromDelete clears the current cache if there is a delete that we don't know about and returns true to the caller if it schedules a background loader job
func (HybridConversationSource) DeleteAssets ¶
func (s HybridConversationSource) DeleteAssets(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, assets []chat1.Asset)
DeleteAssets implements github.com/keybase/go/chat/storage/storage.AssetDeleter interface.
func (*HybridConversationSource) EphemeralPurge ¶
func (s *HybridConversationSource) EphemeralPurge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.EphemeralPurgeInfo) (newPurgeInfo *chat1.EphemeralPurgeInfo, explodedMsgs []chat1.MessageUnboxed, err error)
func (*HybridConversationSource) Expunge ¶ added in v1.0.43
func (s *HybridConversationSource) Expunge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, expunge chat1.Expunge) (err error)
Expunge from storage and maybe notify the gui of staleness
func (*HybridConversationSource) GetMessages ¶ added in v1.0.19
func (s *HybridConversationSource) GetMessages(ctx context.Context, conv types.UnboxConversationInfo, uid gregor1.UID, msgIDs []chat1.MessageID, threadReason *chat1.GetThreadReason) (res []chat1.MessageUnboxed, err error)
func (*HybridConversationSource) GetMessagesWithRemotes ¶ added in v1.0.19
func (s *HybridConversationSource) GetMessagesWithRemotes(ctx context.Context, conv chat1.Conversation, uid gregor1.UID, msgs []chat1.MessageBoxed) ([]chat1.MessageUnboxed, error)
func (*HybridConversationSource) GetUnreadline ¶
func (HybridConversationSource) MarkAsRead ¶
func (*HybridConversationSource) Pull ¶
func (s *HybridConversationSource) Pull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, reason chat1.GetThreadReason, query *chat1.GetThreadQuery, pagination *chat1.Pagination) (thread chat1.ThreadView, err error)
func (HybridConversationSource) PullFull ¶
func (s HybridConversationSource) PullFull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, reason chat1.GetThreadReason, query *chat1.GetThreadQuery, maxPages *int) (res chat1.ThreadView, err error)
func (*HybridConversationSource) PullLocalOnly ¶ added in v1.0.19
func (s *HybridConversationSource) PullLocalOnly(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, query *chat1.GetThreadQuery, pagination *chat1.Pagination, maxPlaceholders int) (tv chat1.ThreadView, err error)
func (*HybridConversationSource) Push ¶
func (s *HybridConversationSource) Push(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, msg chat1.MessageBoxed) (decmsg chat1.MessageUnboxed, continuousUpdate bool, err error)
func (*HybridConversationSource) PushUnboxed ¶ added in v1.0.48
func (s *HybridConversationSource) PushUnboxed(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, msg chat1.MessageUnboxed) (continuousUpdate bool, err error)
func (*HybridConversationSource) ReleaseConversationLock ¶ added in v1.0.48
func (s *HybridConversationSource) ReleaseConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID)
func (HybridConversationSource) SetRemoteInterface ¶ added in v1.0.19
func (s HybridConversationSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
func (HybridConversationSource) Sign ¶
Sign implements github.com/keybase/go/chat/s3.Signer interface.
func (HybridConversationSource) TransformSupersedes ¶ added in v1.0.19
func (s HybridConversationSource) TransformSupersedes(ctx context.Context, unboxInfo types.UnboxConversationInfo, uid gregor1.UID, msgs []chat1.MessageUnboxed) ([]chat1.MessageUnboxed, error)
type HybridInboxSource ¶ added in v1.0.19
type HybridInboxSource struct { sync.Mutex globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewHybridInboxSource ¶ added in v1.0.19
func NewHybridInboxSource(g *globals.Context, badger *badges.Badger, getChatInterface func() chat1.RemoteInterface) *HybridInboxSource
func (*HybridInboxSource) ConversationsUpdate ¶
func (s *HybridInboxSource) ConversationsUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convUpdates []chat1.ConversationUpdate) (err error)
func (HybridInboxSource) Disconnected ¶ added in v1.0.19
func (*HybridInboxSource) Expunge ¶ added in v1.0.43
func (s *HybridInboxSource) Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, expunge chat1.Expunge, maxMsgs []chat1.MessageSummary) (*chat1.ConversationLocal, error)
func (HybridInboxSource) GetInboxQueryLocalToRemote ¶ added in v1.0.27
func (b HybridInboxSource) GetInboxQueryLocalToRemote(ctx context.Context, lquery *chat1.GetInboxLocalQuery) (rquery *chat1.GetInboxQuery, info types.NameInfo, err error)
func (HybridInboxSource) Localize ¶
func (b HybridInboxSource) Localize(ctx context.Context, uid gregor1.UID, convs []types.RemoteConversation, localizerTyp types.ConversationLocalizerTyp) ([]chat1.ConversationLocal, chan types.AsyncInboxResult, error)
func (*HybridInboxSource) MembershipUpdate ¶ added in v1.0.27
func (s *HybridInboxSource) MembershipUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, joined []chat1.ConversationMember, removed []chat1.ConversationMember, resets []chat1.ConversationMember, previews []chat1.ConversationID) (res types.MembershipUpdateRes, err error)
func (*HybridInboxSource) NewConversation ¶ added in v1.0.19
func (s *HybridInboxSource) NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, conv chat1.Conversation) (err error)
func (*HybridInboxSource) NewMessage ¶ added in v1.0.19
func (s *HybridInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, msg chat1.MessageBoxed, maxMsgs []chat1.MessageSummary) (conv *chat1.ConversationLocal, err error)
func (*HybridInboxSource) Read ¶ added in v1.0.19
func (s *HybridInboxSource) Read(ctx context.Context, uid gregor1.UID, localizerTyp types.ConversationLocalizerTyp, dataSource types.InboxSourceDataSourceTyp, maxLocalize *int, query *chat1.GetInboxLocalQuery, p *chat1.Pagination) (inbox types.Inbox, localizeCb chan types.AsyncInboxResult, err error)
func (*HybridInboxSource) ReadMessage ¶ added in v1.0.19
func (s *HybridInboxSource) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, msgID chat1.MessageID) (conv *chat1.ConversationLocal, err error)
func (*HybridInboxSource) ReadUnverified ¶ added in v1.0.19
func (s *HybridInboxSource) ReadUnverified(ctx context.Context, uid gregor1.UID, dataSource types.InboxSourceDataSourceTyp, query *chat1.GetInboxQuery, p *chat1.Pagination) (res types.Inbox, err error)
func (HybridInboxSource) RemoteSetConversationStatus ¶
func (b HybridInboxSource) RemoteSetConversationStatus(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, status chat1.ConversationStatus) (err error)
func (*HybridInboxSource) Search ¶
func (s *HybridInboxSource) Search(ctx context.Context, uid gregor1.UID, query string, limit int) (res []types.RemoteConversation, err error)
func (*HybridInboxSource) SetAppNotificationSettings ¶ added in v1.0.27
func (s *HybridInboxSource) SetAppNotificationSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, settings chat1.ConversationNotificationInfo) (conv *chat1.ConversationLocal, err error)
func (*HybridInboxSource) SetConvRetention ¶ added in v1.0.41
func (s *HybridInboxSource) SetConvRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, policy chat1.RetentionPolicy) (res *chat1.ConversationLocal, err error)
func (*HybridInboxSource) SetConvSettings ¶
func (s *HybridInboxSource) SetConvSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, convSettings *chat1.ConversationSettings) (res *chat1.ConversationLocal, err error)
func (HybridInboxSource) SetRemoteInterface ¶ added in v1.0.19
func (b HybridInboxSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
func (*HybridInboxSource) SetStatus ¶ added in v1.0.19
func (s *HybridInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, status chat1.ConversationStatus) (conv *chat1.ConversationLocal, err error)
func (*HybridInboxSource) SetTeamRetention ¶ added in v1.0.41
func (s *HybridInboxSource) SetTeamRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, teamID keybase1.TeamID, policy chat1.RetentionPolicy) (convs []chat1.ConversationLocal, err error)
func (*HybridInboxSource) Start ¶
func (s *HybridInboxSource) Start(ctx context.Context, uid gregor1.UID)
func (*HybridInboxSource) Stop ¶
func (s *HybridInboxSource) Stop(ctx context.Context) chan struct{}
func (*HybridInboxSource) SubteamRename ¶
func (s *HybridInboxSource) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convIDs []chat1.ConversationID) (convs []chat1.ConversationLocal, err error)
func (*HybridInboxSource) TeamTypeChanged ¶ added in v1.0.30
func (s *HybridInboxSource) TeamTypeChanged(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, teamType chat1.TeamType) (conv *chat1.ConversationLocal, err error)
func (*HybridInboxSource) TlfFinalize ¶ added in v1.0.19
func (s *HybridInboxSource) TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convIDs []chat1.ConversationID, finalizeInfo chat1.ConversationFinalizeInfo) (convs []chat1.ConversationLocal, err error)
func (*HybridInboxSource) UpdateInboxVersion ¶
func (*HybridInboxSource) UpgradeKBFSToImpteam ¶ added in v1.0.41
func (s *HybridInboxSource) UpgradeKBFSToImpteam(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID) (conv *chat1.ConversationLocal, err error)
type IdentifyChangedHandler ¶ added in v1.0.19
type IdentifyChangedHandler struct { globals.Contextified utils.DebugLabeler }
func NewIdentifyChangedHandler ¶ added in v1.0.19
func NewIdentifyChangedHandler(g *globals.Context) *IdentifyChangedHandler
func (*IdentifyChangedHandler) BackgroundIdentifyChanged ¶ added in v1.0.19
func (h *IdentifyChangedHandler) BackgroundIdentifyChanged(ctx context.Context, job engine.IdentifyJob)
func (*IdentifyChangedHandler) HandleUserChanged ¶ added in v1.0.19
func (h *IdentifyChangedHandler) HandleUserChanged(uid keybase1.UID) (err error)
type ImplicitTeamsNameInfoSource ¶ added in v1.0.29
type ImplicitTeamsNameInfoSource struct { globals.Contextified utils.DebugLabeler *NameIdentifier // contains filtered or unexported fields }
func NewImplicitTeamsNameInfoSource ¶ added in v1.0.29
func NewImplicitTeamsNameInfoSource(g *globals.Context, lookupUpgraded bool) *ImplicitTeamsNameInfoSource
func (*ImplicitTeamsNameInfoSource) AllCryptKeys ¶
func (t *ImplicitTeamsNameInfoSource) AllCryptKeys(ctx context.Context, name string, public bool) (res types.AllCryptKeys, err error)
func (*ImplicitTeamsNameInfoSource) DecryptionKey ¶
func (*ImplicitTeamsNameInfoSource) EncryptionKey ¶
func (*ImplicitTeamsNameInfoSource) EphemeralDecryptionKey ¶ added in v1.0.48
func (t *ImplicitTeamsNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool, generation keybase1.EkGeneration, contentCtime *gregor1.Time) (teamEK keybase1.TeamEk, err error)
func (*ImplicitTeamsNameInfoSource) EphemeralEncryptionKey ¶ added in v1.0.48
func (t *ImplicitTeamsNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool) (teamEK keybase1.TeamEk, err error)
func (*ImplicitTeamsNameInfoSource) LookupName ¶
func (*ImplicitTeamsNameInfoSource) ShouldPairwiseMAC ¶
type ImpteamBadteamError ¶
type ImpteamBadteamError struct {
Msg string
}
func (ImpteamBadteamError) Error ¶
func (e ImpteamBadteamError) Error() string
type InvalidMACError ¶
type InvalidMACError struct{}
func NewInvalidMACError ¶
func NewInvalidMACError() InvalidMACError
func (InvalidMACError) Error ¶
func (e InvalidMACError) Error() string
type KBFSNameInfoSource ¶ added in v1.0.27
type KBFSNameInfoSource struct { globals.Contextified utils.DebugLabeler *NameIdentifier }
func NewKBFSNameInfoSource ¶ added in v1.0.27
func NewKBFSNameInfoSource(g *globals.Context) *KBFSNameInfoSource
func (*KBFSNameInfoSource) AllCryptKeys ¶
func (t *KBFSNameInfoSource) AllCryptKeys(ctx context.Context, tlfName string, public bool) (res types.AllCryptKeys, err error)
func (*KBFSNameInfoSource) CompleteAndCanonicalizePrivateTlfName ¶ added in v1.0.27
func (t *KBFSNameInfoSource) CompleteAndCanonicalizePrivateTlfName(ctx context.Context, tlfName string) (res keybase1.CanonicalTLFNameAndIDWithBreaks, err error)
func (*KBFSNameInfoSource) CryptKeys ¶ added in v1.0.27
func (t *KBFSNameInfoSource) CryptKeys(ctx context.Context, tlfName string) (res keybase1.GetTLFCryptKeysRes, ferr error)
func (*KBFSNameInfoSource) DecryptionKey ¶
func (*KBFSNameInfoSource) EncryptionKey ¶
func (*KBFSNameInfoSource) EphemeralDecryptionKey ¶ added in v1.0.48
func (t *KBFSNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool, generation keybase1.EkGeneration, contentCtime *gregor1.Time) (teamEK keybase1.TeamEk, err error)
func (*KBFSNameInfoSource) EphemeralEncryptionKey ¶ added in v1.0.48
func (t *KBFSNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool) (teamEK keybase1.TeamEk, err error)
func (*KBFSNameInfoSource) LookupName ¶
func (*KBFSNameInfoSource) PublicCanonicalTLFNameAndID ¶ added in v1.0.27
func (t *KBFSNameInfoSource) PublicCanonicalTLFNameAndID(ctx context.Context, tlfName string) (res keybase1.CanonicalTLFNameAndIDWithBreaks, ferr error)
func (*KBFSNameInfoSource) ShouldPairwiseMAC ¶
type KeyFinderImpl ¶
type KeyFinderImpl struct { globals.Contextified utils.DebugLabeler sync.Mutex // contains filtered or unexported fields }
KeyFinder remembers results from previous calls to CryptKeys().
func (*KeyFinderImpl) EphemeralKeyForDecryption ¶ added in v1.0.48
func (k *KeyFinderImpl) EphemeralKeyForDecryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool, generation keybase1.EkGeneration, contentCtime *gregor1.Time) (keybase1.TeamEk, error)
func (*KeyFinderImpl) EphemeralKeyForEncryption ¶ added in v1.0.48
func (k *KeyFinderImpl) EphemeralKeyForEncryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool) (ek keybase1.TeamEk, err error)
func (*KeyFinderImpl) FindForDecryption ¶ added in v1.0.27
func (k *KeyFinderImpl) FindForDecryption(ctx context.Context, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool, keyGeneration int, kbfsEncrypted bool) (res types.CryptKey, err error)
FindForDecryption ignores tlfName or teamID based on membersType.
func (*KeyFinderImpl) FindForEncryption ¶ added in v1.0.27
func (k *KeyFinderImpl) FindForEncryption(ctx context.Context, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool) (res types.CryptKey, ni types.NameInfo, err error)
FindForEncryption finds keys up-to-date enough for encrypting. Ignores tlfName or teamID based on membersType.
func (*KeyFinderImpl) Reset ¶ added in v1.0.42
func (k *KeyFinderImpl) Reset()
func (*KeyFinderImpl) ShouldPairwiseMAC ¶
type KeyFinderMock ¶
type KeyFinderMock struct {
// contains filtered or unexported fields
}
func (*KeyFinderMock) EphemeralKeyForDecryption ¶
func (k *KeyFinderMock) EphemeralKeyForDecryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool, generation keybase1.EkGeneration, contentCtime *gregor1.Time) (keybase1.TeamEk, error)
func (*KeyFinderMock) EphemeralKeyForEncryption ¶
func (k *KeyFinderMock) EphemeralKeyForEncryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool) (keybase1.TeamEk, error)
func (*KeyFinderMock) FindForDecryption ¶
func (*KeyFinderMock) FindForEncryption ¶
func (*KeyFinderMock) Reset ¶
func (k *KeyFinderMock) Reset()
func (*KeyFinderMock) SetNameInfoSourceOverride ¶
func (k *KeyFinderMock) SetNameInfoSourceOverride(ni types.NameInfoSource)
func (*KeyFinderMock) ShouldPairwiseMAC ¶
type MobilePush ¶
type MobilePush struct { globals.Contextified utils.DebugLabeler }
func NewMobilePush ¶
func NewMobilePush(g *globals.Context) *MobilePush
func (*MobilePush) AckNotificationSuccess ¶
func (h *MobilePush) AckNotificationSuccess(ctx context.Context, pushIDs []string)
func (*MobilePush) FormatPushText ¶
func (h *MobilePush) FormatPushText(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, membersType chat1.ConversationMembersType, msg chat1.MessageUnboxed) (res string, err error)
func (*MobilePush) UnboxPushNotification ¶
func (h *MobilePush) UnboxPushNotification(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, membersType chat1.ConversationMembersType, payload string) (res chat1.MessageUnboxed, err error)
type NameIdentifier ¶ added in v1.0.29
type NameIdentifier struct { globals.Contextified utils.DebugLabeler }
func NewNameIdentifier ¶ added in v1.0.29
func NewNameIdentifier(g *globals.Context) *NameIdentifier
func (*NameIdentifier) Identify ¶ added in v1.0.29
func (t *NameIdentifier) Identify(ctx context.Context, names []string, private bool, getTLFID func() keybase1.TLFID, getCanonicalName func() keybase1.CanonicalTlfName) (res []keybase1.TLFIdentifyFailure, err error)
type NewConvFindExistingMode ¶
type NewConvFindExistingMode int
const ( NewConvFindExistingNormal NewConvFindExistingMode = iota NewConvFindExistingSkip )
type NonblockingSender ¶ added in v1.0.19
type NonblockingSender struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewNonblockingSender ¶ added in v1.0.19
func NewNonblockingSender(g *globals.Context, sender types.Sender) *NonblockingSender
func (*NonblockingSender) Prepare ¶ added in v1.0.19
func (s *NonblockingSender) Prepare(ctx context.Context, msg chat1.MessagePlaintext, membersType chat1.ConversationMembersType, conv *chat1.ConversationLocal, opts *chat1.SenderPrepareOptions) (types.SenderPrepareResult, error)
func (*NonblockingSender) Send ¶ added in v1.0.19
func (s *NonblockingSender) Send(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, clientPrev chat1.MessageID, outboxID *chat1.OutboxID, sendOpts *chat1.SenderSendOptions, prepareOpts *chat1.SenderPrepareOptions) (chat1.OutboxID, *chat1.MessageBoxed, error)
func (*NonblockingSender) SendUnfurlNonblock ¶
func (s *NonblockingSender) SendUnfurlNonblock(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext, clientPrev chat1.MessageID, outboxID chat1.OutboxID) (chat1.OutboxID, error)
type NotAuthenticatedForThisDeviceError ¶
type NotAuthenticatedForThisDeviceError struct {
// contains filtered or unexported fields
}
func NewNotAuthenticatedForThisDeviceError ¶
func NewNotAuthenticatedForThisDeviceError(mctx libkb.MetaContext, tlfID chat1.TLFID, contentCtime gregor1.Time) NotAuthenticatedForThisDeviceError
func (NotAuthenticatedForThisDeviceError) Error ¶
func (e NotAuthenticatedForThisDeviceError) Error() string
func (NotAuthenticatedForThisDeviceError) InternalError ¶
func (e NotAuthenticatedForThisDeviceError) InternalError() string
type NotifyRouterActivityRouter ¶
type NotifyRouterActivityRouter struct { utils.DebugLabeler globals.Contextified sync.Mutex // contains filtered or unexported fields }
func NewNotifyRouterActivityRouter ¶
func NewNotifyRouterActivityRouter(g *globals.Context) *NotifyRouterActivityRouter
func (*NotifyRouterActivityRouter) Activity ¶
func (n *NotifyRouterActivityRouter) Activity(ctx context.Context, uid gregor1.UID, topicType chat1.TopicType, activity *chat1.ChatActivity, source chat1.ChatActivitySource)
func (*NotifyRouterActivityRouter) AttachmentUploadProgress ¶
func (n *NotifyRouterActivityRouter) AttachmentUploadProgress(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, outboxID chat1.OutboxID, bytesComplete, bytesTotal int64)
func (*NotifyRouterActivityRouter) AttachmentUploadStart ¶
func (n *NotifyRouterActivityRouter) AttachmentUploadStart(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, outboxID chat1.OutboxID)
func (*NotifyRouterActivityRouter) InboxStale ¶
func (n *NotifyRouterActivityRouter) InboxStale(ctx context.Context, uid gregor1.UID)
func (*NotifyRouterActivityRouter) InboxSyncStarted ¶
func (n *NotifyRouterActivityRouter) InboxSyncStarted(ctx context.Context, uid gregor1.UID)
func (*NotifyRouterActivityRouter) InboxSynced ¶
func (n *NotifyRouterActivityRouter) InboxSynced(ctx context.Context, uid gregor1.UID, topicType chat1.TopicType, syncRes chat1.ChatSyncResult)
func (*NotifyRouterActivityRouter) JoinedConversation ¶
func (n *NotifyRouterActivityRouter) JoinedConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType, conv *chat1.InboxUIItem)
func (*NotifyRouterActivityRouter) KBFSToImpteamUpgrade ¶
func (n *NotifyRouterActivityRouter) KBFSToImpteamUpgrade(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType)
func (*NotifyRouterActivityRouter) LeftConversation ¶
func (n *NotifyRouterActivityRouter) LeftConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType)
func (*NotifyRouterActivityRouter) PromptUnfurl ¶
func (n *NotifyRouterActivityRouter) PromptUnfurl(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, msgID chat1.MessageID, domain string)
func (*NotifyRouterActivityRouter) ResetConversation ¶
func (n *NotifyRouterActivityRouter) ResetConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType)
func (*NotifyRouterActivityRouter) SetConvRetention ¶
func (n *NotifyRouterActivityRouter) SetConvRetention(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType, conv *chat1.InboxUIItem)
func (*NotifyRouterActivityRouter) SetConvSettings ¶
func (n *NotifyRouterActivityRouter) SetConvSettings(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType, conv *chat1.InboxUIItem)
func (*NotifyRouterActivityRouter) SetTeamRetention ¶
func (*NotifyRouterActivityRouter) SubteamRename ¶
func (n *NotifyRouterActivityRouter) SubteamRename(ctx context.Context, uid gregor1.UID, convIDs []chat1.ConversationID, topicType chat1.TopicType, convs []chat1.InboxUIItem)
func (*NotifyRouterActivityRouter) TLFFinalize ¶
func (n *NotifyRouterActivityRouter) TLFFinalize(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType, finalizeInfo chat1.ConversationFinalizeInfo, conv *chat1.InboxUIItem)
func (*NotifyRouterActivityRouter) TLFResolve ¶
func (n *NotifyRouterActivityRouter) TLFResolve(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType, resolveInfo chat1.ConversationResolveInfo)
func (*NotifyRouterActivityRouter) ThreadsStale ¶
func (n *NotifyRouterActivityRouter) ThreadsStale(ctx context.Context, uid gregor1.UID, updates []chat1.ConversationStaleUpdate)
func (*NotifyRouterActivityRouter) TypingUpdate ¶
func (n *NotifyRouterActivityRouter) TypingUpdate(ctx context.Context, updates []chat1.ConvTypingUpdate)
type OfflineClient ¶ added in v1.0.27
type OfflineClient struct { }
func (OfflineClient) Call ¶ added in v1.0.27
func (e OfflineClient) Call(ctx context.Context, method string, arg interface{}, res interface{}) error
func (OfflineClient) CallCompressed ¶
func (e OfflineClient) CallCompressed(ctx context.Context, method string, arg interface{}, res interface{}, ctype rpc.CompressionType) error
type OfflineError ¶ added in v1.0.19
type OfflineError struct { }
func (OfflineError) Error ¶ added in v1.0.19
func (e OfflineError) Error() string
type OfflineErrorKind ¶ added in v1.0.46
type OfflineErrorKind int
const ( OfflineErrorKindOnline OfflineErrorKind = iota OfflineErrorKindOfflineBasic OfflineErrorKindOfflineReconnect )
func IsOfflineError ¶ added in v1.0.46
func IsOfflineError(err error) OfflineErrorKind
type PermanentUnboxingError ¶ added in v1.0.19
type PermanentUnboxingError struct {
// contains filtered or unexported fields
}
func (PermanentUnboxingError) Error ¶ added in v1.0.19
func (e PermanentUnboxingError) Error() string
func (PermanentUnboxingError) ExportType ¶ added in v1.0.19
func (e PermanentUnboxingError) ExportType() chat1.MessageUnboxedErrorType
func (PermanentUnboxingError) Inner ¶ added in v1.0.19
func (e PermanentUnboxingError) Inner() error
func (PermanentUnboxingError) InternalError ¶
func (e PermanentUnboxingError) InternalError() string
func (PermanentUnboxingError) IsCritical ¶
func (e PermanentUnboxingError) IsCritical() bool
func (PermanentUnboxingError) IsPermanent ¶ added in v1.0.19
func (e PermanentUnboxingError) IsPermanent() bool
func (PermanentUnboxingError) ToStatus ¶
func (e PermanentUnboxingError) ToStatus() (status keybase1.Status)
func (PermanentUnboxingError) VersionKind ¶
func (e PermanentUnboxingError) VersionKind() chat1.VersionKind
func (PermanentUnboxingError) VersionNumber ¶
func (e PermanentUnboxingError) VersionNumber() int
type PublicTeamEphemeralKeyError ¶
type PublicTeamEphemeralKeyError struct{}
func NewPublicTeamEphemeralKeyError ¶
func NewPublicTeamEphemeralKeyError() PublicTeamEphemeralKeyError
func (PublicTeamEphemeralKeyError) Error ¶
func (e PublicTeamEphemeralKeyError) Error() string
type PushHandler ¶ added in v1.0.19
type PushHandler struct { globals.Contextified utils.DebugLabeler sync.Mutex // contains filtered or unexported fields }
func NewPushHandler ¶ added in v1.0.19
func NewPushHandler(g *globals.Context) *PushHandler
func (*PushHandler) Activity ¶ added in v1.0.19
func (g *PushHandler) Activity(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) ConversationsUpdate ¶
func (g *PushHandler) ConversationsUpdate(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) HandleOobm ¶ added in v1.0.27
func (g *PushHandler) HandleOobm(ctx context.Context, obm gregor.OutOfBandMessage) (bool, error)
func (*PushHandler) MembershipUpdate ¶ added in v1.0.27
func (g *PushHandler) MembershipUpdate(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) SetBadger ¶ added in v1.0.27
func (g *PushHandler) SetBadger(badger *badges.Badger)
func (*PushHandler) SetClock ¶ added in v1.0.27
func (g *PushHandler) SetClock(clock clockwork.Clock)
func (*PushHandler) SetConvRetention ¶ added in v1.0.41
func (g *PushHandler) SetConvRetention(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) SetConvSettings ¶
func (g *PushHandler) SetConvSettings(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) SetTeamRetention ¶ added in v1.0.41
func (g *PushHandler) SetTeamRetention(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) SubteamRename ¶
func (g *PushHandler) SubteamRename(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) TlfFinalize ¶ added in v1.0.19
func (g *PushHandler) TlfFinalize(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) TlfResolve ¶ added in v1.0.19
func (g *PushHandler) TlfResolve(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) Typing ¶ added in v1.0.27
func (g *PushHandler) Typing(ctx context.Context, m gregor.OutOfBandMessage) (err error)
func (*PushHandler) UpgradeKBFSToImpteam ¶ added in v1.0.41
func (g *PushHandler) UpgradeKBFSToImpteam(ctx context.Context, m gregor.OutOfBandMessage) (err error)
type RemoteAttachmentFetcher ¶ added in v1.0.48
type RemoteAttachmentFetcher struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewRemoteAttachmentFetcher ¶ added in v1.0.48
func NewRemoteAttachmentFetcher(g *globals.Context, store attachments.Store) *RemoteAttachmentFetcher
func (*RemoteAttachmentFetcher) DeleteAssets ¶
func (r *RemoteAttachmentFetcher) DeleteAssets(ctx context.Context, convID chat1.ConversationID, assets []chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (err error)
func (*RemoteAttachmentFetcher) FetchAttachment ¶ added in v1.0.48
func (r *RemoteAttachmentFetcher) FetchAttachment(ctx context.Context, w io.Writer, convID chat1.ConversationID, asset chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer, progress types.ProgressReporter) (err error)
func (*RemoteAttachmentFetcher) IsAssetLocal ¶
func (*RemoteAttachmentFetcher) OnDbNuke ¶
func (r *RemoteAttachmentFetcher) OnDbNuke(mctx libkb.MetaContext) error
func (*RemoteAttachmentFetcher) PutUploadedAsset ¶
func (*RemoteAttachmentFetcher) StreamAttachment ¶
func (r *RemoteAttachmentFetcher) StreamAttachment(ctx context.Context, convID chat1.ConversationID, asset chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (res io.ReadSeeker, err error)
type RemoteClient ¶ added in v1.0.22
type RemoteClient struct { utils.DebugLabeler // contains filtered or unexported fields }
func NewRemoteClient ¶ added in v1.0.22
func NewRemoteClient(g *globals.Context, cli rpc.GenericClient) *RemoteClient
func (*RemoteClient) Call ¶ added in v1.0.22
func (c *RemoteClient) Call(ctx context.Context, method string, arg interface{}, res interface{}) (err error)
func (*RemoteClient) CallCompressed ¶
func (c *RemoteClient) CallCompressed(ctx context.Context, method string, arg interface{}, res interface{}, ctype rpc.CompressionType) (err error)
type RemoteConversationSource ¶
type RemoteConversationSource struct { globals.Contextified // contains filtered or unexported fields }
func NewRemoteConversationSource ¶
func NewRemoteConversationSource(g *globals.Context, b *Boxer, ri func() chat1.RemoteInterface) *RemoteConversationSource
func (*RemoteConversationSource) AcquireConversationLock ¶ added in v1.0.48
func (s *RemoteConversationSource) AcquireConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) error
func (*RemoteConversationSource) Clear ¶
func (s *RemoteConversationSource) Clear(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID) error
func (*RemoteConversationSource) ClearFromDelete ¶ added in v1.0.48
func (s *RemoteConversationSource) ClearFromDelete(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, msgID chat1.MessageID) bool
func (RemoteConversationSource) DeleteAssets ¶
func (s RemoteConversationSource) DeleteAssets(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, assets []chat1.Asset)
DeleteAssets implements github.com/keybase/go/chat/storage/storage.AssetDeleter interface.
func (*RemoteConversationSource) EphemeralPurge ¶
func (s *RemoteConversationSource) EphemeralPurge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.EphemeralPurgeInfo) (*chat1.EphemeralPurgeInfo, []chat1.MessageUnboxed, error)
func (*RemoteConversationSource) Expunge ¶ added in v1.0.43
func (s *RemoteConversationSource) Expunge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, expunge chat1.Expunge) error
func (*RemoteConversationSource) GetMessages ¶ added in v1.0.19
func (s *RemoteConversationSource) GetMessages(ctx context.Context, conv types.UnboxConversationInfo, uid gregor1.UID, msgIDs []chat1.MessageID, threadReason *chat1.GetThreadReason) ([]chat1.MessageUnboxed, error)
func (*RemoteConversationSource) GetMessagesWithRemotes ¶ added in v1.0.19
func (s *RemoteConversationSource) GetMessagesWithRemotes(ctx context.Context, conv chat1.Conversation, uid gregor1.UID, msgs []chat1.MessageBoxed) ([]chat1.MessageUnboxed, error)
func (*RemoteConversationSource) GetUnreadline ¶
func (RemoteConversationSource) MarkAsRead ¶
func (*RemoteConversationSource) Pull ¶
func (s *RemoteConversationSource) Pull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, reason chat1.GetThreadReason, query *chat1.GetThreadQuery, pagination *chat1.Pagination) (chat1.ThreadView, error)
func (RemoteConversationSource) PullFull ¶
func (s RemoteConversationSource) PullFull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, reason chat1.GetThreadReason, query *chat1.GetThreadQuery, maxPages *int) (res chat1.ThreadView, err error)
func (*RemoteConversationSource) PullLocalOnly ¶ added in v1.0.19
func (s *RemoteConversationSource) PullLocalOnly(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, query *chat1.GetThreadQuery, pagination *chat1.Pagination, maxPlaceholders int) (chat1.ThreadView, error)
func (*RemoteConversationSource) Push ¶
func (s *RemoteConversationSource) Push(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, msg chat1.MessageBoxed) (chat1.MessageUnboxed, bool, error)
func (*RemoteConversationSource) PushUnboxed ¶ added in v1.0.48
func (s *RemoteConversationSource) PushUnboxed(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, msg chat1.MessageUnboxed) (bool, error)
func (*RemoteConversationSource) ReleaseConversationLock ¶ added in v1.0.48
func (s *RemoteConversationSource) ReleaseConversationLock(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID)
func (RemoteConversationSource) SetRemoteInterface ¶ added in v1.0.19
func (s RemoteConversationSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
func (RemoteConversationSource) Sign ¶
Sign implements github.com/keybase/go/chat/s3.Signer interface.
func (RemoteConversationSource) TransformSupersedes ¶ added in v1.0.19
func (s RemoteConversationSource) TransformSupersedes(ctx context.Context, unboxInfo types.UnboxConversationInfo, uid gregor1.UID, msgs []chat1.MessageUnboxed) ([]chat1.MessageUnboxed, error)
type RemoteInboxSource ¶ added in v1.0.19
type RemoteInboxSource struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewRemoteInboxSource ¶ added in v1.0.19
func NewRemoteInboxSource(g *globals.Context, ri func() chat1.RemoteInterface) *RemoteInboxSource
func (*RemoteInboxSource) ConversationsUpdate ¶
func (s *RemoteInboxSource) ConversationsUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convUpdates []chat1.ConversationUpdate) error
func (RemoteInboxSource) Disconnected ¶ added in v1.0.19
func (*RemoteInboxSource) Expunge ¶ added in v1.0.43
func (s *RemoteInboxSource) Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, expunge chat1.Expunge, maxMsgs []chat1.MessageSummary) (res *chat1.ConversationLocal, err error)
func (RemoteInboxSource) GetInboxQueryLocalToRemote ¶ added in v1.0.27
func (b RemoteInboxSource) GetInboxQueryLocalToRemote(ctx context.Context, lquery *chat1.GetInboxLocalQuery) (rquery *chat1.GetInboxQuery, info types.NameInfo, err error)
func (RemoteInboxSource) Localize ¶
func (b RemoteInboxSource) Localize(ctx context.Context, uid gregor1.UID, convs []types.RemoteConversation, localizerTyp types.ConversationLocalizerTyp) ([]chat1.ConversationLocal, chan types.AsyncInboxResult, error)
func (*RemoteInboxSource) MembershipUpdate ¶ added in v1.0.27
func (s *RemoteInboxSource) MembershipUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, joined []chat1.ConversationMember, removed []chat1.ConversationMember, resets []chat1.ConversationMember, previews []chat1.ConversationID) (res types.MembershipUpdateRes, err error)
func (*RemoteInboxSource) NewConversation ¶ added in v1.0.19
func (s *RemoteInboxSource) NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, conv chat1.Conversation) error
func (*RemoteInboxSource) NewMessage ¶ added in v1.0.19
func (s *RemoteInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, msg chat1.MessageBoxed, maxMsgs []chat1.MessageSummary) (*chat1.ConversationLocal, error)
func (*RemoteInboxSource) Read ¶ added in v1.0.19
func (s *RemoteInboxSource) Read(ctx context.Context, uid gregor1.UID, localizerTyp types.ConversationLocalizerTyp, dataSource types.InboxSourceDataSourceTyp, maxLocalize *int, query *chat1.GetInboxLocalQuery, p *chat1.Pagination) (types.Inbox, chan types.AsyncInboxResult, error)
func (*RemoteInboxSource) ReadMessage ¶ added in v1.0.19
func (s *RemoteInboxSource) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, msgID chat1.MessageID) (*chat1.ConversationLocal, error)
func (*RemoteInboxSource) ReadUnverified ¶ added in v1.0.19
func (s *RemoteInboxSource) ReadUnverified(ctx context.Context, uid gregor1.UID, dataSource types.InboxSourceDataSourceTyp, rquery *chat1.GetInboxQuery, p *chat1.Pagination) (types.Inbox, error)
func (RemoteInboxSource) RemoteSetConversationStatus ¶
func (b RemoteInboxSource) RemoteSetConversationStatus(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID, status chat1.ConversationStatus) (err error)
func (*RemoteInboxSource) Search ¶
func (s *RemoteInboxSource) Search(ctx context.Context, uid gregor1.UID, query string, limit int) (res []types.RemoteConversation, err error)
func (*RemoteInboxSource) SetAppNotificationSettings ¶ added in v1.0.27
func (s *RemoteInboxSource) SetAppNotificationSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, settings chat1.ConversationNotificationInfo) (*chat1.ConversationLocal, error)
func (*RemoteInboxSource) SetConvRetention ¶ added in v1.0.41
func (s *RemoteInboxSource) SetConvRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, policy chat1.RetentionPolicy) (res *chat1.ConversationLocal, err error)
func (*RemoteInboxSource) SetConvSettings ¶
func (s *RemoteInboxSource) SetConvSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, convSettings *chat1.ConversationSettings) (res *chat1.ConversationLocal, err error)
func (RemoteInboxSource) SetRemoteInterface ¶ added in v1.0.19
func (b RemoteInboxSource) SetRemoteInterface(ri func() chat1.RemoteInterface)
func (*RemoteInboxSource) SetStatus ¶ added in v1.0.19
func (s *RemoteInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, status chat1.ConversationStatus) (*chat1.ConversationLocal, error)
func (*RemoteInboxSource) SetTeamRetention ¶ added in v1.0.41
func (s *RemoteInboxSource) SetTeamRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, teamID keybase1.TeamID, policy chat1.RetentionPolicy) (res []chat1.ConversationLocal, err error)
func (*RemoteInboxSource) SubteamRename ¶
func (s *RemoteInboxSource) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convIDs []chat1.ConversationID) (convs []chat1.ConversationLocal, err error)
func (*RemoteInboxSource) TeamTypeChanged ¶ added in v1.0.41
func (s *RemoteInboxSource) TeamTypeChanged(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, teamType chat1.TeamType) (conv *chat1.ConversationLocal, err error)
func (*RemoteInboxSource) TlfFinalize ¶ added in v1.0.19
func (s *RemoteInboxSource) TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convIDs []chat1.ConversationID, finalizeInfo chat1.ConversationFinalizeInfo) ([]chat1.ConversationLocal, error)
func (*RemoteInboxSource) UpdateInboxVersion ¶
func (*RemoteInboxSource) UpgradeKBFSToImpteam ¶
func (s *RemoteInboxSource) UpgradeKBFSToImpteam(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID) (conv *chat1.ConversationLocal, err error)
type ReplyFiller ¶
type ReplyFiller struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewReplyFiller ¶
func NewReplyFiller(g *globals.Context, config ...func(*ReplyFiller)) *ReplyFiller
func (*ReplyFiller) Fill ¶
func (f *ReplyFiller) Fill(ctx context.Context, uid gregor1.UID, conv types.UnboxConversationInfo, msgs []chat1.MessageUnboxed) (res []chat1.MessageUnboxed, err error)
func (*ReplyFiller) FillSingle ¶
func (f *ReplyFiller) FillSingle(ctx context.Context, uid gregor1.UID, conv types.UnboxConversationInfo, msg chat1.MessageUnboxed) (res chat1.MessageUnboxed, err error)
func (*ReplyFiller) SetLocalOnlyReplyFill ¶
func (f *ReplyFiller) SetLocalOnlyReplyFill(enabled bool)
type SenderTestImmediateFailError ¶
type SenderTestImmediateFailError struct { }
func (SenderTestImmediateFailError) Error ¶
func (e SenderTestImmediateFailError) Error() string
func (SenderTestImmediateFailError) IsImmediateFail ¶
func (e SenderTestImmediateFailError) IsImmediateFail() (chat1.OutboxErrorType, bool)
type Server ¶ added in v1.0.22
type Server struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewServer ¶ added in v1.0.22
func NewServer(g *globals.Context, serverConn ServerConnection, uiSource UISource) *Server
func (*Server) AddTeamMemberAfterReset ¶ added in v1.0.39
func (*Server) BulkAddToConv ¶
func (*Server) CancelActiveInboxSearch ¶
func (*Server) CancelActiveSearch ¶
func (*Server) CancelPost ¶ added in v1.0.22
func (*Server) DeleteConversationLocal ¶ added in v1.0.31
func (h *Server) DeleteConversationLocal(ctx context.Context, arg chat1.DeleteConversationLocalArg) (res chat1.DeleteConversationLocalRes, err error)
func (*Server) DownloadAttachmentLocal ¶ added in v1.0.22
func (h *Server) DownloadAttachmentLocal(ctx context.Context, arg chat1.DownloadAttachmentLocalArg) (res chat1.DownloadAttachmentLocalRes, err error)
DownloadAttachmentLocal implements chat1.LocalInterface.DownloadAttachmentLocal.
func (*Server) DownloadFileAttachmentLocal ¶ added in v1.0.22
func (h *Server) DownloadFileAttachmentLocal(ctx context.Context, arg chat1.DownloadFileAttachmentLocalArg) (res chat1.DownloadFileAttachmentLocalRes, err error)
DownloadFileAttachmentLocal implements chat1.LocalInterface.DownloadFileAttachmentLocal.
func (*Server) FindConversationsLocal ¶ added in v1.0.22
func (h *Server) FindConversationsLocal(ctx context.Context, arg chat1.FindConversationsLocalArg) (res chat1.FindConversationsLocalRes, err error)
func (*Server) GenerateOutboxID ¶ added in v1.0.27
func (*Server) GetCachedThread ¶ added in v1.0.22
func (h *Server) GetCachedThread(ctx context.Context, arg chat1.GetCachedThreadArg) (res chat1.GetThreadLocalRes, err error)
func (*Server) GetConversationForCLILocal ¶ added in v1.0.22
func (h *Server) GetConversationForCLILocal(ctx context.Context, arg chat1.GetConversationForCLILocalQuery) (res chat1.GetConversationForCLILocalRes, err error)
func (*Server) GetGlobalAppNotificationSettingsLocal ¶ added in v1.0.27
func (*Server) GetInboxAndUnboxLocal ¶ added in v1.0.22
func (h *Server) GetInboxAndUnboxLocal(ctx context.Context, arg chat1.GetInboxAndUnboxLocalArg) (res chat1.GetInboxAndUnboxLocalRes, err error)
GetInboxAndUnboxLocal implements keybase.chatLocal.getInboxAndUnboxLocal protocol.
func (*Server) GetInboxAndUnboxUILocal ¶
func (h *Server) GetInboxAndUnboxUILocal(ctx context.Context, arg chat1.GetInboxAndUnboxUILocalArg) (res chat1.GetInboxAndUnboxUILocalRes, err error)
func (*Server) GetInboxNonblockLocal ¶ added in v1.0.22
func (h *Server) GetInboxNonblockLocal(ctx context.Context, arg chat1.GetInboxNonblockLocalArg) (res chat1.NonblockFetchRes, err error)
func (*Server) GetInboxSummaryForCLILocal ¶ added in v1.0.22
func (h *Server) GetInboxSummaryForCLILocal(ctx context.Context, arg chat1.GetInboxSummaryForCLILocalQuery) (res chat1.GetInboxSummaryForCLILocalRes, err error)
func (*Server) GetMessagesLocal ¶ added in v1.0.22
func (h *Server) GetMessagesLocal(ctx context.Context, arg chat1.GetMessagesLocalArg) (res chat1.GetMessagesLocalRes, err error)
func (*Server) GetNextAttachmentMessageLocal ¶
func (h *Server) GetNextAttachmentMessageLocal(ctx context.Context, arg chat1.GetNextAttachmentMessageLocalArg) (res chat1.GetNextAttachmentMessageLocalRes, err error)
func (*Server) GetStaticConfig ¶
func (*Server) GetTLFConversationsLocal ¶ added in v1.0.27
func (h *Server) GetTLFConversationsLocal(ctx context.Context, arg chat1.GetTLFConversationsLocalArg) (res chat1.GetTLFConversationsLocalRes, err error)
func (*Server) GetTeamRetentionLocal ¶ added in v1.0.46
func (*Server) GetThreadLocal ¶ added in v1.0.22
func (h *Server) GetThreadLocal(ctx context.Context, arg chat1.GetThreadLocalArg) (res chat1.GetThreadLocalRes, err error)
GetThreadLocal implements keybase.chatLocal.getThreadLocal protocol.
func (*Server) GetThreadNonblock ¶ added in v1.0.22
func (h *Server) GetThreadNonblock(ctx context.Context, arg chat1.GetThreadNonblockArg) (res chat1.NonblockFetchRes, fullErr error)
func (*Server) GetUnfurlSettings ¶
func (*Server) GetUnreadline ¶
func (h *Server) GetUnreadline(ctx context.Context, arg chat1.GetUnreadlineArg) (res chat1.UnreadlineRes, err error)
func (*Server) GetUploadTempFile ¶
func (*Server) JoinConversationByIDLocal ¶ added in v1.0.27
func (h *Server) JoinConversationByIDLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)
func (*Server) JoinConversationLocal ¶ added in v1.0.27
func (h *Server) JoinConversationLocal(ctx context.Context, arg chat1.JoinConversationLocalArg) (res chat1.JoinLeaveConversationLocalRes, err error)
func (*Server) LeaveConversationLocal ¶ added in v1.0.27
func (h *Server) LeaveConversationLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)
func (*Server) LoadFlip ¶
func (h *Server) LoadFlip(ctx context.Context, arg chat1.LoadFlipArg) (res chat1.LoadFlipRes, err error)
func (*Server) LoadGallery ¶
func (h *Server) LoadGallery(ctx context.Context, arg chat1.LoadGalleryArg) (res chat1.LoadGalleryRes, err error)
func (*Server) MakePreview ¶ added in v1.0.22
func (h *Server) MakePreview(ctx context.Context, arg chat1.MakePreviewArg) (res chat1.MakePreviewRes, err error)
MakePreview implements chat1.LocalInterface.MakePreview.
func (*Server) MakeUploadTempFile ¶
func (*Server) MarkAsReadLocal ¶ added in v1.0.22
func (h *Server) MarkAsReadLocal(ctx context.Context, arg chat1.MarkAsReadLocalArg) (res chat1.MarkAsReadLocalRes, err error)
func (*Server) NewConversationLocal ¶ added in v1.0.22
func (h *Server) NewConversationLocal(ctx context.Context, arg chat1.NewConversationLocalArg) (res chat1.NewConversationLocalRes, err error)
NewConversationLocal implements keybase.chatLocal.newConversationLocal protocol. Create a new conversation. Or in the case of CHAT, create-or-get a conversation.
func (*Server) PostDeleteHistoryByAge ¶ added in v1.0.40
func (h *Server) PostDeleteHistoryByAge(ctx context.Context, arg chat1.PostDeleteHistoryByAgeArg) (res chat1.PostLocalRes, err error)
func (*Server) PostDeleteHistoryThrough ¶ added in v1.0.43
func (h *Server) PostDeleteHistoryThrough(ctx context.Context, arg chat1.PostDeleteHistoryThroughArg) (res chat1.PostLocalRes, err error)
func (*Server) PostDeleteHistoryUpto ¶ added in v1.0.40
func (h *Server) PostDeleteHistoryUpto(ctx context.Context, arg chat1.PostDeleteHistoryUptoArg) (res chat1.PostLocalRes, err error)
func (*Server) PostDeleteNonblock ¶ added in v1.0.22
func (h *Server) PostDeleteNonblock(ctx context.Context, arg chat1.PostDeleteNonblockArg) (chat1.PostLocalNonblockRes, error)
func (*Server) PostEditNonblock ¶ added in v1.0.22
func (h *Server) PostEditNonblock(ctx context.Context, arg chat1.PostEditNonblockArg) (res chat1.PostLocalNonblockRes, err error)
func (*Server) PostFileAttachmentLocal ¶ added in v1.0.22
func (h *Server) PostFileAttachmentLocal(ctx context.Context, arg chat1.PostFileAttachmentLocalArg) (res chat1.PostLocalRes, err error)
PostFileAttachmentLocal implements chat1.LocalInterface.PostFileAttachmentLocal.
func (*Server) PostFileAttachmentLocalNonblock ¶
func (h *Server) PostFileAttachmentLocalNonblock(ctx context.Context, arg chat1.PostFileAttachmentLocalNonblockArg) (res chat1.PostLocalNonblockRes, err error)
func (*Server) PostHeadline ¶ added in v1.0.29
func (h *Server) PostHeadline(ctx context.Context, arg chat1.PostHeadlineArg) (chat1.PostLocalRes, error)
func (*Server) PostHeadlineNonblock ¶ added in v1.0.29
func (h *Server) PostHeadlineNonblock(ctx context.Context, arg chat1.PostHeadlineNonblockArg) (chat1.PostLocalNonblockRes, error)
func (*Server) PostLocal ¶ added in v1.0.22
func (h *Server) PostLocal(ctx context.Context, arg chat1.PostLocalArg) (res chat1.PostLocalRes, err error)
PostLocal implements keybase.chatLocal.postLocal protocol.
func (*Server) PostLocalNonblock ¶ added in v1.0.22
func (h *Server) PostLocalNonblock(ctx context.Context, arg chat1.PostLocalNonblockArg) (res chat1.PostLocalNonblockRes, err error)
func (*Server) PostMetadata ¶ added in v1.0.34
func (h *Server) PostMetadata(ctx context.Context, arg chat1.PostMetadataArg) (chat1.PostLocalRes, error)
func (*Server) PostMetadataNonblock ¶ added in v1.0.34
func (h *Server) PostMetadataNonblock(ctx context.Context, arg chat1.PostMetadataNonblockArg) (chat1.PostLocalNonblockRes, error)
func (*Server) PostReactionNonblock ¶
func (h *Server) PostReactionNonblock(ctx context.Context, arg chat1.PostReactionNonblockArg) (res chat1.PostLocalNonblockRes, err error)
func (*Server) PostTextNonblock ¶ added in v1.0.22
func (h *Server) PostTextNonblock(ctx context.Context, arg chat1.PostTextNonblockArg) (res chat1.PostLocalNonblockRes, err error)
func (*Server) PreviewConversationByIDLocal ¶ added in v1.0.34
func (h *Server) PreviewConversationByIDLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)
func (*Server) ProfileChatSearch ¶
func (h *Server) ProfileChatSearch(ctx context.Context, identifyBehavior keybase1.TLFIdentifyBehavior) (res map[string]chat1.ProfileSearchConvStats, err error)
func (*Server) PutReacjiSkinTone ¶
func (h *Server) PutReacjiSkinTone(ctx context.Context, skinTone keybase1.ReacjiSkinTone) (res keybase1.UserReacjis, err error)
func (*Server) ResolveMaybeMention ¶
func (*Server) ResolveUnfurlPrompt ¶
func (*Server) SaveUnfurlSettings ¶
func (*Server) SearchInbox ¶
func (h *Server) SearchInbox(ctx context.Context, arg chat1.SearchInboxArg) (res chat1.SearchInboxRes, err error)
func (*Server) SearchRegexp ¶
func (h *Server) SearchRegexp(ctx context.Context, arg chat1.SearchRegexpArg) (res chat1.SearchRegexpRes, err error)
func (*Server) SetAppNotificationSettingsLocal ¶ added in v1.0.27
func (h *Server) SetAppNotificationSettingsLocal(ctx context.Context, arg chat1.SetAppNotificationSettingsLocalArg) (res chat1.SetAppNotificationSettingsLocalRes, err error)
func (*Server) SetConvMinWriterRoleLocal ¶
func (*Server) SetConvRetentionLocal ¶ added in v1.0.40
func (*Server) SetConversationStatusLocal ¶ added in v1.0.22
func (h *Server) SetConversationStatusLocal(ctx context.Context, arg chat1.SetConversationStatusLocalArg) (res chat1.SetConversationStatusLocalRes, err error)
func (*Server) SetGlobalAppNotificationSettingsLocal ¶ added in v1.0.27
func (*Server) SetTeamRetentionLocal ¶ added in v1.0.40
func (*Server) ToggleMessageCollapse ¶
func (*Server) UnboxMobilePushNotification ¶ added in v1.0.27
func (*Server) UpdateTyping ¶ added in v1.0.27
func (*Server) UpdateUnsentText ¶
func (*Server) UpgradeKBFSConversationToImpteam ¶ added in v1.0.41
type ServerConnection ¶ added in v1.0.22
type SimpleIdentifyNotifier ¶ added in v1.0.42
type SimpleIdentifyNotifier struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewSimpleIdentifyNotifier ¶ added in v1.0.42
func NewSimpleIdentifyNotifier(g *globals.Context) *SimpleIdentifyNotifier
func (*SimpleIdentifyNotifier) Reset ¶ added in v1.0.42
func (d *SimpleIdentifyNotifier) Reset()
func (*SimpleIdentifyNotifier) ResetOnGUIConnect ¶ added in v1.0.42
func (d *SimpleIdentifyNotifier) ResetOnGUIConnect()
func (*SimpleIdentifyNotifier) Send ¶ added in v1.0.42
func (d *SimpleIdentifyNotifier) Send(ctx context.Context, update keybase1.CanonicalTLFNameAndIDWithBreaks)
type Syncer ¶ added in v1.0.19
type Syncer struct { globals.Contextified utils.DebugLabeler sync.Mutex // contains filtered or unexported fields }
func (*Syncer) Connected ¶ added in v1.0.19
func (s *Syncer) Connected(ctx context.Context, cli chat1.RemoteInterface, uid gregor1.UID, syncRes *chat1.SyncChatRes) (err error)
func (*Syncer) Disconnected ¶ added in v1.0.19
func (*Syncer) GetSelectedConversation ¶ added in v1.0.48
func (s *Syncer) GetSelectedConversation() chat1.ConversationID
func (*Syncer) IsConnected ¶ added in v1.0.21
func (*Syncer) RegisterOfflinable ¶ added in v1.0.19
func (s *Syncer) RegisterOfflinable(offlinable types.Offlinable)
func (*Syncer) SelectConversation ¶ added in v1.0.47
func (s *Syncer) SelectConversation(ctx context.Context, convID chat1.ConversationID)
func (*Syncer) SendChatStaleNotifications ¶ added in v1.0.19
type TeamChannelSource ¶
type TeamChannelSource struct { globals.Contextified utils.DebugLabeler }
func NewTeamChannelSource ¶
func NewTeamChannelSource(g *globals.Context) *TeamChannelSource
func (*TeamChannelSource) GetChannelTopicName ¶
func (*TeamChannelSource) GetChannelsFull ¶
func (*TeamChannelSource) GetChannelsTopicName ¶
type TeamLoader ¶ added in v1.0.47
type TeamLoader struct { libkb.Contextified utils.DebugLabeler }
func NewTeamLoader ¶ added in v1.0.47
func NewTeamLoader(g *libkb.GlobalContext) *TeamLoader
type TeamMentionLoader ¶
type TeamMentionLoader struct { sync.Mutex globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewTeamMentionLoader ¶
func NewTeamMentionLoader(g *globals.Context) *TeamMentionLoader
func (*TeamMentionLoader) IsTeamMention ¶
func (l *TeamMentionLoader) IsTeamMention(ctx context.Context, uid gregor1.UID, maybeMention chat1.MaybeMention, knownTeamMentions []chat1.KnownTeamMention) bool
func (*TeamMentionLoader) LoadTeamMention ¶
func (l *TeamMentionLoader) LoadTeamMention(ctx context.Context, uid gregor1.UID, maybeMention chat1.MaybeMention, knownTeamMentions []chat1.KnownTeamMention, forceRemote bool) (err error)
func (*TeamMentionLoader) Start ¶
func (l *TeamMentionLoader) Start(ctx context.Context, uid gregor1.UID)
func (*TeamMentionLoader) Stop ¶
func (l *TeamMentionLoader) Stop(ctx context.Context) chan struct{}
type TeamsNameInfoSource ¶ added in v1.0.27
type TeamsNameInfoSource struct { globals.Contextified utils.DebugLabeler // contains filtered or unexported fields }
func NewTeamsNameInfoSource ¶ added in v1.0.27
func NewTeamsNameInfoSource(g *globals.Context) *TeamsNameInfoSource
func (*TeamsNameInfoSource) AllCryptKeys ¶
func (t *TeamsNameInfoSource) AllCryptKeys(ctx context.Context, name string, public bool) (res types.AllCryptKeys, err error)
func (*TeamsNameInfoSource) DecryptionKey ¶
func (*TeamsNameInfoSource) EncryptionKey ¶
func (*TeamsNameInfoSource) EphemeralDecryptionKey ¶ added in v1.0.48
func (t *TeamsNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool, generation keybase1.EkGeneration, contentCtime *gregor1.Time) (teamEK keybase1.TeamEk, err error)
func (*TeamsNameInfoSource) EphemeralEncryptionKey ¶ added in v1.0.48
func (t *TeamsNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID, membersType chat1.ConversationMembersType, public bool) (teamEK keybase1.TeamEk, err error)
func (*TeamsNameInfoSource) LookupName ¶
func (*TeamsNameInfoSource) ShouldPairwiseMAC ¶
type TransientUnboxingError ¶ added in v1.0.19
type TransientUnboxingError struct {
// contains filtered or unexported fields
}
func (TransientUnboxingError) Error ¶ added in v1.0.19
func (e TransientUnboxingError) Error() string
func (TransientUnboxingError) ExportType ¶ added in v1.0.19
func (e TransientUnboxingError) ExportType() chat1.MessageUnboxedErrorType
func (TransientUnboxingError) Inner ¶ added in v1.0.19
func (e TransientUnboxingError) Inner() error
func (TransientUnboxingError) InternalError ¶
func (e TransientUnboxingError) InternalError() string
func (TransientUnboxingError) IsCritical ¶
func (e TransientUnboxingError) IsCritical() bool
func (TransientUnboxingError) IsPermanent ¶ added in v1.0.19
func (e TransientUnboxingError) IsPermanent() bool
func (TransientUnboxingError) ToStatus ¶
func (e TransientUnboxingError) ToStatus() (status keybase1.Status)
func (TransientUnboxingError) VersionKind ¶
func (e TransientUnboxingError) VersionKind() chat1.VersionKind
func (TransientUnboxingError) VersionNumber ¶
func (e TransientUnboxingError) VersionNumber() int
type TypingMonitor ¶ added in v1.0.27
type TypingMonitor struct { globals.Contextified sync.Mutex utils.DebugLabeler // contains filtered or unexported fields }
func NewTypingMonitor ¶ added in v1.0.27
func NewTypingMonitor(g *globals.Context) *TypingMonitor
func (*TypingMonitor) SetClock ¶ added in v1.0.27
func (t *TypingMonitor) SetClock(clock clockwork.Clock)
func (*TypingMonitor) SetTimeout ¶ added in v1.0.27
func (t *TypingMonitor) SetTimeout(timeout time.Duration)
func (*TypingMonitor) Update ¶ added in v1.0.27
func (t *TypingMonitor) Update(ctx context.Context, typer chat1.TyperInfo, convID chat1.ConversationID, typing bool)
type UISource ¶ added in v1.0.22
type UISource interface { GetChatUI(sessionID int) libkb.ChatUI GetStreamUICli() *keybase1.StreamUiClient }
type UnknownTLFNameError ¶
type UnknownTLFNameError struct {
// contains filtered or unexported fields
}
func NewUnknownTLFNameError ¶
func NewUnknownTLFNameError(name string) UnknownTLFNameError
func (UnknownTLFNameError) Error ¶
func (e UnknownTLFNameError) Error() string
type VersionError ¶ added in v1.0.19
func NewBodyVersionError ¶ added in v1.0.19
func NewBodyVersionError(version chat1.BodyPlaintextVersion, defaultBody chat1.BodyPlaintextUnsupported) VersionError
func NewHeaderVersionError ¶ added in v1.0.19
func NewHeaderVersionError(version chat1.HeaderPlaintextVersion, defaultHeader chat1.HeaderPlaintextUnsupported) VersionError
func NewMessageBoxedVersionError ¶ added in v1.0.19
func NewMessageBoxedVersionError(version chat1.MessageBoxedVersion) VersionError
func (VersionError) Error ¶ added in v1.0.19
func (e VersionError) Error() string
func (VersionError) ExportType ¶ added in v1.0.19
func (e VersionError) ExportType() chat1.MessageUnboxedErrorType
func (VersionError) IsCritical ¶
func (e VersionError) IsCritical() bool
func (VersionError) VersionKind ¶
func (e VersionError) VersionKind() chat1.VersionKind
func (VersionError) VersionNumber ¶
func (e VersionError) VersionNumber() int
Source Files ¶
- activitynotifier.go
- attachment_httpsrv.go
- boxer.go
- convloader.go
- convsource.go
- ctx_factory.go
- devstorage.go
- ephemeral_purger.go
- errors.go
- flipmanager.go
- helper.go
- identify.go
- identify_ui.go
- inboxsource.go
- keyfinder.go
- localizer.go
- mobilepush.go
- notification_settings.go
- prev.go
- push.go
- remoteclient.go
- replyto.go
- retry.go
- sender.go
- server.go
- sourceofflinable.go
- supersedes.go
- sync.go
- teamchannelsource.go
- teammentionloader.go
- teams.go
- tlf.go
- typingmonitor.go
- upakfinder.go