Home
last modified time | relevance | path

Searched refs:InboxVers (Results 1 – 25 of 32) sorted by relevance

12

/dports/security/keybase/client-v5.7.1/go/protocol/chat1/
H A Dgregor.go23 InboxVers: o.InboxVers.DeepCopy(),
48 InboxVers: o.InboxVers.DeepCopy(),
76 InboxVers: o.InboxVers.DeepCopy(),
114 InboxVers: o.InboxVers.DeepCopy(),
140 InboxVers: o.InboxVers.DeepCopy(),
166 InboxVers: o.InboxVers.DeepCopy(),
191 InboxVers: o.InboxVers.DeepCopy(),
218 InboxVers: o.InboxVers.DeepCopy(),
291 InboxVers: o.InboxVers.DeepCopy(),
303 InboxVers: o.InboxVers.DeepCopy(),
[all …]
H A Dremote.go383 InboxVers InboxVers `codec:"inboxVers" json:"inboxVers"` member
391 InboxVers: o.InboxVers.DeepCopy(),
430 Vers InboxVers `codec:"vers" json:"vers"`
452 InboxVers int `codec:"inboxVers" json:"inboxVers"` member
458 InboxVers: o.InboxVers,
1634 Vers InboxVers `codec:"vers" json:"vers"`
1696 InboxVers InboxVers `codec:"inboxVers" json:"inboxVers"` member
1713 Vers InboxVers `codec:"vers" json:"vers"`
1726 InboxVers InboxVers `codec:"inboxVers" json:"inboxVers"` member
1915 SyncInbox(context.Context, InboxVers) (SyncInboxRes, error) argument
[all …]
H A Dcommon.go82 type InboxVers uint64 type
84 func (o InboxVers) DeepCopy() InboxVers {
135 Vers InboxVers `codec:"vers" json:"vers"`
1707 Vers InboxVers `codec:"vers" json:"vers"`
/dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/keybase/go-keybase-chat-bot/kbchat/types/chat1/
H A Dgregor.go22 InboxVers: o.InboxVers.DeepCopy(),
47 InboxVers: o.InboxVers.DeepCopy(),
75 InboxVers: o.InboxVers.DeepCopy(),
113 InboxVers: o.InboxVers.DeepCopy(),
139 InboxVers: o.InboxVers.DeepCopy(),
165 InboxVers: o.InboxVers.DeepCopy(),
190 InboxVers: o.InboxVers.DeepCopy(),
217 InboxVers: o.InboxVers.DeepCopy(),
290 InboxVers: o.InboxVers.DeepCopy(),
302 InboxVers: o.InboxVers.DeepCopy(),
[all …]
H A Dremote.go381 InboxVers InboxVers `codec:"inboxVers" json:"inboxVers"` member
389 InboxVers: o.InboxVers.DeepCopy(),
428 Vers InboxVers `codec:"vers" json:"vers"`
450 InboxVers int `codec:"inboxVers" json:"inboxVers"` member
456 InboxVers: o.InboxVers,
H A Dcommon.go82 type InboxVers uint64 type
84 func (o InboxVers) DeepCopy() InboxVers {
135 Vers InboxVers `codec:"vers" json:"vers"`
1707 Vers InboxVers `codec:"vers" json:"vers"`
/dports/security/keybase/client-v5.7.1/protocol/avdl/chat1/
H A Dgregor.avdl10 InboxVers inboxVers;
20 InboxVers inboxVers;
30 InboxVers inboxVers;
44 InboxVers inboxVers;
54 InboxVers inboxVers;
64 InboxVers inboxVers;
73 InboxVers inboxVers;
83 InboxVers inboxVers;
105 InboxVers inboxVers;
110 InboxVers inboxVers;
[all …]
H A Dremote.avdl120 …GetInboxRemoteRes getInboxRemote(InboxVers vers, union { null, GetInboxQuery } query, union { null…
162 UnreadUpdateFull GetUnreadUpdateFull(InboxVers inboxVers);
168 InboxVers inboxVers;
193 InboxVers getInboxVersion(gregor1.UID uid);
196 InboxVers vers;
212 SyncInboxRes syncInbox(InboxVers vers);
219 …SyncChatRes syncChat(InboxVers vers, boolean summarizeMaxMsgs, InboxParticipantsMode participantsM…
244 …egor1.UID uid, gregor1.DeviceID deviceID, gregor1.SessionToken session, InboxVers inboxVers, grego…
H A Dcommon.avdl14 @typedef("uint64") @lint("ignore") record InboxVers {}
23 InboxVers vers;
547 InboxVers vers;
/dports/security/keybase/client-v5.7.1/go/chat/
H A Dpush_test.go30 iboxXform func(chat1.InboxVers) chat1.InboxVers) { argument
64 InboxVers: iboxXform(vers),
96 func(vers chat1.InboxVers) chat1.InboxVers { return vers + 1 })
105 func(vers chat1.InboxVers) chat1.InboxVers { return vers + 2 })
113 func(vers chat1.InboxVers) chat1.InboxVers { return vers + 1 })
129 func(vers chat1.InboxVers) chat1.InboxVers { return vers + 2 })
170 func(vers chat1.InboxVers) chat1.InboxVers { return vers + 1 })
178 func(vers chat1.InboxVers) chat1.InboxVers { return vers + 1 })
H A Dpush.go32 vers chat1.InboxVers
76 msgVers chat1.InboxVers) (res []messageWaiterEntry) {
124 newVers chat1.InboxVers) (res chan struct{}) {
280 cb := g.orderer.WaitForTurn(ctx, uid, update.InboxVers)
286 defer g.orderer.CompleteTurn(ctx, uid, update.InboxVers)
340 cb := g.orderer.WaitForTurn(ctx, uid, update.InboxVers)
346 defer g.orderer.CompleteTurn(ctx, uid, update.InboxVers)
535 cb := g.orderer.WaitForTurn(ctx, uid, gm.InboxVers)
541 defer g.orderer.CompleteTurn(ctx, uid, gm.InboxVers)
974 cb := g.orderer.WaitForTurn(ctx, uid, update.InboxVers)
[all …]
H A Dinboxsource_test.go46 require.Equal(t, chat1.InboxVers(0), ib.Version, "wrong version")
72 require.Equal(t, chat1.InboxVers(1), ib.Version, "wrong version")
91 require.Equal(t, chat1.InboxVers(v), ib.Version, "wrong version")
101 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
145 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
147 require.Equal(t, chat1.InboxVers(0), vers)
163 … = tc.ChatG.InboxSource.NewMessage(context.TODO(), u.User.GetUID().ToBytes(), chat1.InboxVers(100),
H A Dinboxsource.go387 func (s *RemoteInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
392 func (s *RemoteInboxSource) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
397 func (s *RemoteInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
407 func (s *RemoteInboxSource) TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
445 …nc (s *RemoteInboxSource) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
456 vers chat1.InboxVers, convID chat1.ConversationID) (conv *chat1.ConversationLocal, err error) {
461 vers chat1.InboxVers) error {
1021 var vers chat1.InboxVers
1366 func (s *HybridInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
1395 func (s *HybridInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
[all …]
H A Dsync_test.go124 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
138 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
166 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
201 require.Equal(t, chat1.InboxVers(100), vers)
210 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
411 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
552 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
619 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
688 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
734 …ri.SyncInboxFunc = func(m *kbtest.ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat…
[all …]
/dports/security/keybase/client-v5.7.1/go/chat/storage/
H A Dversion_test.go16 InboxVers: 10,
23 require.Equal(t, 10, res.InboxVers)
27 InboxVers: 10,
H A Derrors.go90 old, new chat1.InboxVers
93 func NewVersionMismatchError(oldVers chat1.InboxVers, newVers chat1.InboxVers) VersionMismatchError… argument
H A Dversion.go76 return retVers, NewVersionMismatchError(chat1.InboxVers(vers), chat1.InboxVers(retVers))
85 …return s.matchLocked(ctx, vers, func(srvVers chat1.ServerCacheVers) int { return srvVers.InboxVers…
H A Dinbox.go106 InboxVersion chat1.InboxVers `codec:"I"`
248 ibox.ServerVersion = vers.InboxVers
500 func (i *Inbox) Merge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
752 …handleVersion(ctx context.Context, ourvers chat1.InboxVers, updatevers chat1.InboxVers) (chat1.Inb…
775 func (i *Inbox) NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
986 func (i *Inbox) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
1090 func (i *Inbox) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
1140 func (i *Inbox) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
1237 func (i *Inbox) Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
1290 func (i *Inbox) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
[all …]
/dports/security/keybase/client-v5.7.1/go/badges/
H A Dbadger.go18 GetInboxVersion(context.Context, gregor1.UID) (chat1.InboxVers, error)
24 …nboxVersionSource) GetInboxVersion(ctx context.Context, uid gregor1.UID) (chat1.InboxVers, error) {
25 return chat1.InboxVers(0), nil
87 …Badger) PushChatUpdate(ctx context.Context, update chat1.UnreadUpdate, inboxVers chat1.InboxVers) {
103 func (b *Badger) GetInboxVersionForTest(ctx context.Context) (chat1.InboxVers, error) {
H A Dbadgestate.go46 inboxVers chat1.InboxVers
69 inboxVers: chat1.InboxVers(0),
92 b.state.InboxVers = int(b.inboxVers)
421 inboxVers chat1.InboxVers, isMobile bool) {
443 if update.InboxVers < b.inboxVers {
458 b.inboxVers = update.InboxVers
466 b.inboxVers = chat1.InboxVers(0)
/dports/security/keybase/client-v5.7.1/go/chat/types/
H A Dinterfaces.go188 NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, argument
192 NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, argument
194 …ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationI… argument
196 SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, argument
198 SetAppNotificationSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, argument
200 TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, argument
202 MembershipUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, argument
206 ConversationsUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, argument
210 UpgradeKBFSToImpteam(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, argument
212 Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID, argument
[all …]
/dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/keybase/go-keybase-chat-bot/kbchat/types/keybase1/
H A Dnotify_badges.go95 InboxVers int `codec:"inboxVers" json:"inboxVers"` member
119 InboxVers: o.InboxVers,
/dports/security/keybase/client-v5.7.1/go/protocol/keybase1/
H A Dnotify_badges.go98 InboxVers int `codec:"inboxVers" json:"inboxVers"` member
122 InboxVers: o.InboxVers,
/dports/security/keybase/client-v5.7.1/shared/constants/types/
H A Drpc-chat-gen.tsx1319 export type InboxVers = Uint64
1320 export type InboxVersInfo = {readonly uid: Gregor1.UID; readonly vers: InboxVers}
1322 export type InboxViewFull = {readonly vers: InboxVers; readonly conversations?: Array<Conversation>…
1326 …amUpgradeUpdate = {readonly convID: ConversationID; readonly inboxVers: InboxVers; readonly topicT…
1471 export type SetConvRetentionUpdate = {readonly inboxVers: InboxVers; readonly convID: ConversationI…
1472 export type SetConvSettingsUpdate = {readonly inboxVers: InboxVers; readonly convID: ConversationID…
1480 export type SetTeamRetentionUpdate = {readonly inboxVers: InboxVers; readonly teamID: Keybase1.Team…
1485 …teamRenameUpdate = {readonly convIDs?: Array<ConversationID> | null; readonly inboxVers: InboxVers}
1491 export type SyncIncrementalRes = {readonly vers: InboxVers; readonly convs?: Array<Conversation> | …
1496 export type TLFResolveUpdate = {readonly convID: ConversationID; readonly inboxVers: InboxVers}
[all …]
/dports/security/keybase/client-v5.7.1/go/kbtest/
H A Dchat.go395 …SyncInboxFunc func(m *ChatRemoteMock, ctx context.Context, vers chat1.InboxVers) (chat1.Sync…
838 func (m *ChatRemoteMock) GetUnreadUpdateFull(ctx context.Context, inboxVers chat1.InboxVers) (chat1…
842 func (m *ChatRemoteMock) GetInboxVersion(ctx context.Context, uid gregor1.UID) (chat1.InboxVers, er…
846 func (m *ChatRemoteMock) SyncInbox(ctx context.Context, vers chat1.InboxVers) (chat1.SyncInboxRes, …
867 InboxVers: m.CacheInboxVersion,
875 Vers: arg.InboxVers,

12