this repo has no description
Merge branch 'main' into bnewbold/rerelay
+23
-2
+5
api/atproto/syncdefs.go
+5
api/atproto/syncdefs.go
+9
-1
cmd/goat/firehose.go
+9
-1
cmd/goat/firehose.go
···
51
51
Usage: "only print account and identity events",
52
52
},
53
53
&cli.BoolFlag{
54
+
Name: "blocks",
55
+
Usage: "include blocks as base64 in payload",
56
+
},
57
+
&cli.BoolFlag{
54
58
Name: "quiet",
55
59
Aliases: []string{"q"},
56
60
Usage: "don't actually print events to stdout (eg, errors only)",
···
80
84
OpsMode bool
81
85
AccountsOnly bool
82
86
Quiet bool
87
+
Blocks bool
83
88
VerifyBasic bool
84
89
VerifySig bool
85
90
VerifyMST bool
···
108
113
AccountsOnly: cctx.Bool("account-events"),
109
114
CollectionFilter: cctx.StringSlice("collection"),
110
115
Quiet: cctx.Bool("quiet"),
116
+
Blocks: cctx.Bool("blocks"),
111
117
VerifyBasic: cctx.Bool("verify-basic"),
112
118
VerifySig: cctx.Bool("verify-sig"),
113
119
VerifyMST: cctx.Bool("verify-mst"),
···
389
395
}
390
396
}
391
397
392
-
evt.Blocks = nil
398
+
if !gfc.Blocks {
399
+
evt.Blocks = nil
400
+
}
393
401
out := make(map[string]interface{})
394
402
out["type"] = "commit"
395
403
out["payload"] = evt
+2
did/doc.go
+2
did/doc.go
+3
-1
events/schedulers/parallel/parallel.go
+3
-1
events/schedulers/parallel/parallel.go
···
11
11
"github.com/prometheus/client_golang/prometheus"
12
12
)
13
13
14
-
// Scheduler is a parallel scheduler that will run work on a fixed number of workers
14
+
// Scheduler is a parallel scheduler that will run work on a fixed number of workers.
15
+
//
16
+
// Notably, this scheduler uses a per-DID task tracker to ensure that events are not processed concurrently for the same account. This does *not* mean that all events for the same DID are consistently processed by the same worker.
15
17
type Scheduler struct {
16
18
maxConcurrency int
17
19
maxQueue int
+2
handles/doc.go
+2
handles/doc.go