Home
last modified time | relevance | path

Searched refs:gregor1 (Results 1 – 25 of 270) sorted by relevance

1234567891011

/dports/security/keybase/client-v5.7.1/go/gregor/utils/
H A Dutils.go10 func NewGregorMsgID() (gregor1.MsgID, error) {
15 return gregor1.MsgID(r), nil
18 func TemplateMessage(uid gregor1.UID) (gregor1.Message, error) {
21 return gregor1.Message{}, err
23 return gregor1.Message{
24 Ibm_: &gregor1.InBandMessage{
26 Md_: gregor1.Metadata{
42 Category_: gregor1.Category(cat),
43 Body_: gregor1.Body(body),
55 MsgIDs_: []gregor1.MsgID{gregor1.MsgID(id.Bytes())},
[all …]
/dports/security/keybase/client-v5.7.1/go/chat/types/
H A Dinterfaces.go27 Start(ctx context.Context, uid gregor1.UID)
89 uid gregor1.UID, msg []chat1.MessageUnboxed) error
256 Fix(ctx context.Context, uid gregor1.UID) error
257 SendStale(ctx context.Context, uid gregor1.UID)
302 …GetLastActiveForTLF(context.Context, gregor1.UID, chat1.TLFID, chat1.TopicType) (gregor1.Time, err…
310 …tx context.Context, teamID keybase1.TeamID, uid gregor1.UID, remoteClient chat1.RemoteInterface) (…
336 InboxSyncStarted(ctx context.Context, uid gregor1.UID)
338 InboxStale(ctx context.Context, uid gregor1.UID)
351 PromptUnfurl(ctx context.Context, uid gregor1.UID,
541 LoadTeamMention(ctx context.Context, uid gregor1.UID,
[all …]
H A Dtypes.go49 VerifiedMembers []gregor1.UID // may be empty if we couldn't satisfy the request
66 func (m MembershipUpdateRes) AllOtherUsers() (res []gregor1.UID) {
125 LocalMtime gregor1.Time `codec:"t"`
155 func (rc RemoteConversation) GetMtime() gregor1.Time {
367 AtMentions []gregor1.UID
389 Uids []gregor1.UID
477 func (d DummyEphemeralPurger) Start(ctx context.Context, uid gregor1.UID) {}
491 func (d DummyIndexer) Start(ctx context.Context, uid gregor1.UID) {}
721 func (d DummyUIInboxLoader) Start(ctx context.Context, uid gregor1.UID) {}
806 dataSource InboxSourceDataSourceTyp) ([]gregor1.UID, error) {
[all …]
/dports/security/keybase/client-v5.7.1/go/service/
H A Dgregor_test.go71 m := gregor1.Message{
74 Md_: gregor1.Metadata{
201 m := gregor1.Message{
204 Md_: gregor1.Metadata{
234 Md_: gregor1.Metadata{
342 func (m mockGregord) newIbm(uid gregor1.UID) gregor1.Message {
344 return gregor1.Message{
361 func (m mockGregord) newIbm2(uid gregor1.UID, category gregor1.Category, body gregor1.Body) gregor1…
363 return gregor1.Message{
383 return gregor1.Message{
[all …]
H A Dgregor.go114 var tmp []gregor1.OutOfBandMessage
179 cli gregor1.IncomingInterface
222 broadcastCh chan gregor1.Message
714 return gregor1.Message{
754 t = gregor1.ToTime(*pt)
877 go func(m gregor1.Message) {
1718 …UpdateItem(ctx context.Context, msgID gregor1.MsgID, cat string, body []byte, dtime gregor1.TimeOr…
1746 dtime gregor1.TimeOrOffset) (res gregor1.MsgID, err error) {
1763 Ranges_: []gregor1.MsgRange{
1789 msg := gregor1.Message{
[all …]
H A Dteam_handler.go86 func (r *teamHandler) rotateTeam(ctx context.Context, cli gregor1.IncomingInterface, item gregor.It…
130 func (r *teamHandler) memberOutFromReset(ctx context.Context, cli gregor1.IncomingInterface, item g…
154 func (r *teamHandler) abandonTeam(ctx context.Context, cli gregor1.IncomingInterface, item gregor.I…
174 func (r *teamHandler) gotForceRepoll(ctx context.Context, cli gregor1.IncomingInterface, item grego…
179 func (r *teamHandler) changeTeam(ctx context.Context, cli gregor1.IncomingInterface, category strin…
200 func (r *teamHandler) deleteTeam(ctx context.Context, cli gregor1.IncomingInterface, item gregor.It…
211 func (r *teamHandler) exitTeam(ctx context.Context, cli gregor1.IncomingInterface, item gregor.Item…
240 func (r *teamHandler) newlyAddedToTeam(ctx context.Context, cli gregor1.IncomingInterface, item gre…
259 func (r *teamHandler) sharingBeforeSignup(ctx context.Context, cli gregor1.IncomingInterface, item …
310 func (r *teamHandler) memberShowcaseChange(ctx context.Context, cli gregor1.IncomingInterface, item…
[all …]
/dports/security/keybase/client-v5.7.1/protocol/avdl/keybase1/
H A Dgregor.avdl4 import idl "../gregor1" as gregor1;
5 gregor1.State getState();
6 gregor1.MsgID injectItem(string cat, string body, gregor1.TimeOrOffset dtime);
7 void dismissCategory(gregor1.Category category);
8 void dismissItem(gregor1.MsgID id);
9 …gregor1.MsgID updateItem(gregor1.MsgID msgID, string cat, string body, gregor1.TimeOrOffset dtime);
10 gregor1.MsgID updateCategory(string category, string body, gregor1.TimeOrOffset dtime);
H A Dgregor_ui.avdl4 import idl "../gregor1" as gregor1;
12 void pushState(gregor1.State state, PushReason reason) oneway;
13 void pushOutOfBandMessages(array<gregor1.OutOfBandMessage> oobm) oneway;
/dports/security/keybase/client-v5.7.1/go/protocol/keybase1/
H A Dgregor.go7 gregor1 "github.com/keybase/client/go/protocol/gregor1" packageName
19 Dtime gregor1.TimeOrOffset `codec:"dtime" json:"dtime"`
23 Category gregor1.Category `codec:"category" json:"category"`
27 Id gregor1.MsgID `codec:"id" json:"id"`
31 MsgID gregor1.MsgID `codec:"msgID" json:"msgID"`
34 Dtime gregor1.TimeOrOffset `codec:"dtime" json:"dtime"`
40 Dtime gregor1.TimeOrOffset `codec:"dtime" json:"dtime"`
44 GetState(context.Context) (gregor1.State, error)
45 InjectItem(context.Context, InjectItemArg) (gregor1.MsgID, error)
46 DismissCategory(context.Context, gregor1.Category) error
[all …]
H A Dgregor_ui.go8 gregor1 "github.com/keybase/client/go/protocol/gregor1" packageName
44 State gregor1.State `codec:"state" json:"state"`
49 Oobm []gregor1.OutOfBandMessage `codec:"oobm" json:"oobm"`
54 PushOutOfBandMessages(context.Context, []gregor1.OutOfBandMessage) error
104 func (c GregorUIClient) PushOutOfBandMessages(ctx context.Context, oobm []gregor1.OutOfBandMessage)…
/dports/security/keybase/client-v5.7.1/go/libkb/
H A Dgregor_stub.go17 return gregor1.State{}, nil
21 dtime gregor1.TimeOrOffset) (gregor1.MsgID, error) {
22 return gregor1.MsgID{}, nil
25 …jectItem(ctx context.Context, cat string, body []byte, dtime gregor1.TimeOrOffset) (gregor1.MsgID,…
26 return gregor1.MsgID{}, nil
29 func (n nullGregorState) DismissItem(ctx context.Context, cli gregor1.IncomingInterface,
38 func (n nullGregorState) DismissCategory(ctx context.Context, cat gregor1.Category) error {
/dports/security/keybase/client-v5.7.1/protocol/
H A DMakefile22 build-stamp: avdl/keybase1/*.avdl avdl/gregor1/*.avdl avdl/chat1/*.avdl avdl/stellar1/*.avdl $(AVDL…
24 @mkdir -p json/gregor1
28 $(AVDL2JSON) -2 -b -o json/gregor1 -f workaround avdl/gregor1/*.avdl
33 go-build-stamp: avdl/keybase1/*.avdl avdl/gregor1/*.avdl avdl/chat1/*.avdl avdl/stellar1/*.avdl $(A…
35 @mkdir -p ../go/protocol/gregor1
40 $(AVDLC) -b -l go -o ../go/protocol/gregor1 avdl/gregor1/*.avdl
53 build-go-bot-types: avdl/keybase1/*.avdl avdl/gregor1/*.avdl avdl/chat1/*.avdl avdl/stellar1/*.avdl…
55 $(AVDLC) -b -l go -t -o ../../go-keybase-chat-bot/kbchat/types/gregor1 avdl/gregor1/*.avdl
63 $(AVDLC) -c -b -l go -o ../go/protocol/gregor1 avdl/gregor1/*.avdl
/dports/security/keybase/client-v5.7.1/go/chat/wallet/
H A Dsender_test.go32 func (m *mockUIDMapper) addUser(uid gregor1.UID, username string) {
36 func (m *mockUIDMapper) getUser(uid gregor1.UID) string {
53 partsFn func() []gregor1.UID
57 dataSource types.InboxSourceDataSourceTyp) ([]gregor1.UID, error) {
101 mikeUID := gregor1.UID([]byte{0, 1})
102 patrickUID := gregor1.UID([]byte{0, 2})
103 maxUID := gregor1.UID([]byte{0, 4})
138 mikePatrickFn := func() []gregor1.UID {
139 return []gregor1.UID{mikeUID, patrickUID}
144 allFn := func() []gregor1.UID {
[all …]
/dports/security/keybase/client-v5.7.1/go/chat/
H A Dteamchannelsource.go21 mtime gregor1.Time
53 mtime: gregor1.ToTime(time.Now()),
74 lastActiveAt gregor1.Time
75 mtime gregor1.Time
94 func (i *lastActiveAtMemCache) Get(teamID keybase1.TeamID, uid gregor1.UID) (gregor1.Time, bool) {
107 func (i *lastActiveAtMemCache) Put(teamID keybase1.TeamID, uid gregor1.UID, lastActiveAt gregor1.Ti…
112 mtime: gregor1.ToTime(time.Now()),
180 tlfID chat1.TLFID, topicType chat1.TopicType) (res gregor1.Time, err error) {
211 channels := make(map[chat1.ConvIDStr]gregor1.Time, len(inbox.ConvsUnverified))
218 teams := make(map[chat1.TLFIDStr]gregor1.Time, len(byTLFID))
[all …]
H A Dactivitynotifier.go50 func (n *NotifyRouterActivityRouter) kuid(uid gregor1.UID) keybase1.UID {
54 func (n *NotifyRouterActivityRouter) Activity(ctx context.Context, uid gregor1.UID,
109 func (n *NotifyRouterActivityRouter) LeftConversation(ctx context.Context, uid gregor1.UID,
163 func (n *NotifyRouterActivityRouter) SubteamRename(ctx context.Context, uid gregor1.UID,
180 func (n *NotifyRouterActivityRouter) InboxSynced(ctx context.Context, uid gregor1.UID,
189 func (n *NotifyRouterActivityRouter) InboxStale(ctx context.Context, uid gregor1.UID) {
197 func (n *NotifyRouterActivityRouter) ThreadsStale(ctx context.Context, uid gregor1.UID,
206 func (n *NotifyRouterActivityRouter) TLFFinalize(ctx context.Context, uid gregor1.UID,
215 func (n *NotifyRouterActivityRouter) TLFResolve(ctx context.Context, uid gregor1.UID,
243 func (n *NotifyRouterActivityRouter) PromptUnfurl(ctx context.Context, uid gregor1.UID,
[all …]
H A Dinboxsource.go226 func (b *baseInboxSource) Start(ctx context.Context, uid gregor1.UID) {
298 func (s *RemoteInboxSource) Read(ctx context.Context, uid gregor1.UID,
332 func (s *RemoteInboxSource) ReadUnverified(ctx context.Context, uid gregor1.UID,
350 uid gregor1.UID, msgID *chat1.MessageID) (err error) {
498 uid gregor1.UID
594 func (s *HybridInboxSource) Start(ctx context.Context, uid gregor1.UID) {
863 uid gregor1.UID, msgID *chat1.MessageID) (err error) {
967 func (s *HybridInboxSource) Read(ctx context.Context, uid gregor1.UID,
1116 var htime gregor1.Time
1137 var htime, otime gregor1.Time
[all …]
H A Dkeyfinder.go51 public bool, botUID *gregor1.UID) string {
56 generation int, public bool, kbfsEncrypted bool, botUID *gregor1.UID) string {
119 keyGeneration int, kbfsEncrypted bool, botUID *gregor1.UID) (res types.CryptKey, err error) {
136 …membersType chat1.ConversationMembersType, public bool, botUID *gregor1.UID) (ek types.EphemeralCr…
142 membersType chat1.ConversationMembersType, public bool, botUID *gregor1.UID,
143 generation keybase1.EkGeneration, contentCtime *gregor1.Time) (types.EphemeralCryptKey, error) {
168 botUID *gregor1.UID) (res types.CryptKey, ni types.NameInfo, err error) {
178 keyGeneration int, kbfsEncrypted bool, botUID *gregor1.UID) (res types.CryptKey, err error) {
191 …membersType chat1.ConversationMembersType, public bool, botUID *gregor1.UID) (types.EphemeralCrypt…
196 membersType chat1.ConversationMembersType, public bool, botUID *gregor1.UID,
[all …]
H A Dephemeral_purge_tracker.go63 func (t *EphemeralTracker) Start(ctx context.Context, uid gregor1.UID) {
93 func (t *EphemeralTracker) flushLoop(uid gregor1.UID, stopCh chan struct{}) error {
114 func (t *EphemeralTracker) key(uid gregor1.UID, convID chat1.ConversationID) string {
118 func (t *EphemeralTracker) dbKey(uid gregor1.UID, convID chat1.ConversationID) libkb.DbKey {
167 func (t *EphemeralTracker) Flush(ctx context.Context, uid gregor1.UID) error {
173 func (t *EphemeralTracker) flushLocked(ctx context.Context, uid gregor1.UID) error {
200 uid gregor1.UID, convID chat1.ConversationID) (chat1.EphemeralPurgeInfo, error) {
269 convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.EphemeralPurgeInfo) (err error) {
287 convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.EphemeralPurgeInfo) (err error) {
321 convID chat1.ConversationID, uid gregor1.UID) (err error) {
[all …]
/dports/security/keybase/client-v5.7.1/protocol/avdl/chat1/
H A Dremote.avdl5 import idl "../gregor1" as gregor1;
140 array<gregor1.UID> atMentions,
232 case STATE: gregor1.State;
237 gregor1.AuthResult auth;
251 …void tlfResolve(TLFID tlfID, array<gregor1.UID> resolvedWriters, array<gregor1.UID> resolvedReader…
333 gregor1.Time now;
369 gregor1.UID uid;
373 gregor1.Time mtime;
439 array<gregor1.UID> uids;
446 gregor1.Time lastActiveAt;
[all …]
H A Dcommon.avdl3 import idl "../gregor1" as gregor1;
22 gregor1.UID uid;
133 gregor1.UID uid;
304 gregor1.Time ctime;
305 gregor1.UID uid;
309 gregor1.Time ctime;
314 gregor1.UID uid;
355 gregor1.Time ctime;
379 gregor1.Time now;
661 gregor1.Time time;
[all …]
/dports/security/keybase/client-v5.7.1/go/gregor/client/
H A Dclient.go25 OutboxSend chan gregor1.Message
30 OutboxSend: make(chan gregor1.Message, 10),
42 incomingClient func() gregor1.IncomingInterface
187 arg := gregor1.SyncArg{
188 Uid: gregor1.UID(c.User.Bytes()),
192 arg.Ctime = gregor1.ToTime(*t)
198 syncResult = new(gregor1.SyncResult)
210 m := gregor1.Message{Ibm_: &ibm}
284 var syncResult *gregor1.SyncResult
331 arg := gregor1.StateArg{
[all …]
/dports/security/keybase/client-v5.7.1/go/chat/storage/
H A Dinbox_memcache.go28 func (i *inboxMemCacheImpl) GetVersions(uid gregor1.UID) *inboxDiskVersions {
37 func (i *inboxMemCacheImpl) PutVersions(uid gregor1.UID, ibox *inboxDiskVersions) {
43 func (i *inboxMemCacheImpl) GetIndex(uid gregor1.UID) *inboxDiskIndex {
53 func (i *inboxMemCacheImpl) PutIndex(uid gregor1.UID, ibox *inboxDiskIndex) {
59 func (i *inboxMemCacheImpl) convKey(uid gregor1.UID, convID chat1.ConversationID) string {
63 func (i *inboxMemCacheImpl) GetConv(uid gregor1.UID, convID chat1.ConversationID) *types.RemoteConv…
73 func (i *inboxMemCacheImpl) PutConv(uid gregor1.UID, conv types.RemoteConversation) {
79 func (i *inboxMemCacheImpl) Clear(uid gregor1.UID) {
H A Dreacjis.go70 MtimeMap map[string]gregor1.Time
79 mtime = gregor1.ToTime(time.Now().Add(-time.Hour * 24 * 7))
96 MtimeMap: make(map[string]gregor1.Time),
103 uid gregor1.UID
113 func (i *reacjiMemCacheImpl) Get(uid gregor1.UID) (bool, ReacjiInternalStorage) {
122 func (i *reacjiMemCacheImpl) Put(uid gregor1.UID, data ReacjiInternalStorage) {
198 func (s *ReacjiStore) dbKey(uid gregor1.UID) libkb.DbKey {
235 entry.Data.MtimeMap = make(map[string]gregor1.Time)
263 cache.MtimeMap[shortCode] = gregor1.ToTime(time.Now())
277 func (s *ReacjiStore) PutSkinTone(ctx context.Context, uid gregor1.UID,
[all …]
H A Dinbox_test.go64 Ctime: gregor1.ToTime(time.Now()),
106 conv := makeConvo(gregor1.Time(1), 1, 1)
224 atime := gregor1.Time(15)
234 btime := gregor1.Time(15)
721 return gregor1.UID(b)
864 resetUsers := []gregor1.UID{uid4}
877 resetUsers := []gregor1.UID{uid}
906 makeConvo(gregor1.Time(1), 1, 1),
907 makeConvo(gregor1.Time(0), 1, 1),
911 mtime1 := gregor1.Time(5)
[all …]
/dports/security/keybase/client-v5.7.1/go/protocol/chat1/
H A Dcommon.go716 Before: (func(x *gregor1.Time) *gregor1.Time {
723 After: (func(x *gregor1.Time) *gregor1.Time {
920 ActiveList: (func(x []gregor1.UID) []gregor1.UID {
924 ret := make([]gregor1.UID, len(x))
931 AllList: (func(x []gregor1.UID) []gregor1.UID {
935 ret := make([]gregor1.UID, len(x))
942 ResetList: (func(x []gregor1.UID) []gregor1.UID {
946 ret := make([]gregor1.UID, len(x))
1285 Rtime: (func(x *gregor1.Time) *gregor1.Time {
1466 BotUID: (func(x *gregor1.UID) *gregor1.UID {
[all …]

1234567891011