···

       
14
       
14
       
 
       


     

       
15
       
15
       
 
       
func main() {

     

       
16
       
16
       
 
       
	app := cli.App{

     

       
17
       
17
       
-
       
		Name:   "photocopy",

     

       
18
       
18
       
-
       
		Usage:  "bigquery inserter for firehose events",

     

       
19
       
19
       
-
       
		Action: run,

     

       
17
       
17
       
+
       
		Name:  "photocopy",

     

       
18
       
18
       
+
       
		Usage: "bigquery inserter for firehose events",

     

       
20
       
19
       
 
       
		Flags: []cli.Flag{

     

       
21
       
20
       
 
       
			&cli.StringFlag{

     

       
22
       
21
       
 
       
				Name:    "relay-host",

     
···

       
44
       
43
       
 
       
				Required: true,

     

       
45
       
44
       
 
       
			},

     

       
46
       
45
       
 
       
			&cli.StringFlag{

     

       
46
       
46
       
+
       
				Name:     "clickhouse-addr",

     

       
47
       
47
       
+
       
				EnvVars:  []string{"PHOTOCOPY_CLICKHOUSE_ADDR"},

     

       
48
       
48
       
+
       
				Required: true,

     

       
49
       
49
       
+
       
			},

     

       
50
       
50
       
+
       
			&cli.StringFlag{

     

       
51
       
51
       
+
       
				Name:     "clickhouse-database",

     

       
52
       
52
       
+
       
				EnvVars:  []string{"PHOTOCOPY_CLICKHOUSE_DATABASE"},

     

       
53
       
53
       
+
       
				Required: true,

     

       
54
       
54
       
+
       
			},

     

       
55
       
55
       
+
       
			&cli.StringFlag{

     

       
47
       
56
       
 
       
				Name:    "clickhouse-user",

     

       
48
       
57
       
 
       
				EnvVars: []string{"PHOTOCOPY_CLICKHOUSE_USER"},

     

       
49
       
58
       
 
       
				Value:   "default",

     
···

       
54
       
63
       
 
       
				Required: true,

     

       
55
       
64
       
 
       
			},

     

       
56
       
65
       
 
       
		},

     

       
66
       
66
       
+
       
		Commands: cli.Commands{

     

       
67
       
67
       
+
       
			&cli.Command{

     

       
68
       
68
       
+
       
				Name:   "run",

     

       
69
       
69
       
+
       
				Action: run,

     

       
70
       
70
       
+
       
			},

     

       
71
       
71
       
+
       
			&cli.Command{

     

       
72
       
72
       
+
       
				Name:   "fetch-repos",

     

       
73
       
73
       
+
       
				Action: runFetchRepos,

     

       
74
       
74
       
+
       
			},

     

       
75
       
75
       
+
       
		},

     

       
57
       
76
       
 
       
		ErrWriter: os.Stderr,

     

       
58
       
77
       
 
       
	}

     

       
59
       
78
       
 
       


     
···

       
89
       
108
       
 
       
		MetricsAddr:          cmd.String("metrics-addr"),

     

       
90
       
109
       
 
       
		CursorFile:           cmd.String("cursor-file"),

     

       
91
       
110
       
 
       
		PLCScraperCursorFile: cmd.String("plc-scraper-cursor-file"),

     

       
111
       
111
       
+
       
		ClickhouseAddr:       cmd.String("clickhouse-addr"),

     

       
112
       
112
       
+
       
		ClickhouseDatabase:   cmd.String("clickhouse-database"),

     

       
92
       
113
       
 
       
		ClickhouseUser:       cmd.String("clickhouse-user"),

     

       
93
       
114
       
 
       
		ClickhousePass:       cmd.String("clickhouse-pass"),

     

       
94
       
115
       
 
       
	})

     
···

       
111
       
132
       
 
       


     

       
112
       
133
       
 
       
	return nil

     

       
113
       
134
       
 
       
}

     

       
135
       
135
       
+
       


     

       
136
       
136
       
+
       
var runFetchRepos = func(cmd *cli.Context) error {

     

       
137
       
137
       
+
       
	ctx := cmd.Context

     

       
138
       
138
       
+
       
	ctx, cancel := context.WithCancel(ctx)

     

       
139
       
139
       
+
       
	defer cancel()

     

       
140
       
140
       
+
       


     

       
141
       
141
       
+
       
	return nil

     

       
142
       
142
       
+
       
}

     

···

       
3
       
3
       
 
       
go 1.24.4

     

       
4
       
4
       
 
       


     

       
5
       
5
       
 
       
require (

     

       
6
       
6
       
-
       
	cloud.google.com/go/bigquery v1.69.0

     

       
6
       
6
       
+
       
	github.com/ClickHouse/clickhouse-go v1.5.4

     

       
7
       
7
       
+
       
	github.com/ClickHouse/clickhouse-go/v2 v2.37.2

     

       
7
       
8
       
 
       
	github.com/araddon/dateparse v0.0.0-20210429162001-6b43995a97de

     

       
8
       
9
       
 
       
	github.com/bluesky-social/indigo v0.0.0-20250626183556-5641d3c27325

     

       
9
       
10
       
 
       
	github.com/gorilla/websocket v1.5.1

     
···

       
14
       
15
       
 
       
)

     

       
15
       
16
       
 
       


     

       
16
       
17
       
 
       
require (

     

       
17
       
17
       
-
       
	cloud.google.com/go v0.121.0 // indirect

     

       
18
       
18
       
-
       
	cloud.google.com/go/auth v0.16.1 // indirect

     

       
19
       
19
       
-
       
	cloud.google.com/go/auth/oauth2adapt v0.2.8 // indirect

     

       
20
       
20
       
-
       
	cloud.google.com/go/compute/metadata v0.6.0 // indirect

     

       
21
       
21
       
-
       
	cloud.google.com/go/iam v1.5.2 // indirect

     

       
18
       
18
       
+
       
	github.com/ClickHouse/ch-go v0.66.1 // indirect

     

       
22
       
19
       
 
       
	github.com/RussellLuo/slidingwindow v0.0.0-20200528002341-535bb99d338b // indirect

     

       
23
       
23
       
-
       
	github.com/apache/arrow/go/v15 v15.0.2 // indirect

     

       
20
       
20
       
+
       
	github.com/andybalholm/brotli v1.1.1 // indirect

     

       
24
       
21
       
 
       
	github.com/beorn7/perks v1.0.1 // indirect

     

       
25
       
22
       
 
       
	github.com/carlmjohnson/versioninfo v0.22.5 // indirect

     

       
26
       
23
       
 
       
	github.com/cespare/xxhash/v2 v2.3.0 // indirect

     

       
24
       
24
       
+
       
	github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58 // indirect

     

       
27
       
25
       
 
       
	github.com/cpuguy83/go-md2man/v2 v2.0.3 // indirect

     

       
28
       
26
       
 
       
	github.com/felixge/httpsnoop v1.0.4 // indirect

     

       
27
       
27
       
+
       
	github.com/go-faster/city v1.0.1 // indirect

     

       
28
       
28
       
+
       
	github.com/go-faster/errors v0.7.1 // indirect

     

       
29
       
29
       
 
       
	github.com/go-logr/logr v1.4.2 // indirect

     

       
30
       
30
       
 
       
	github.com/go-logr/stdr v1.2.2 // indirect

     

       
31
       
31
       
-
       
	github.com/goccy/go-json v0.10.2 // indirect

     

       
32
       
31
       
 
       
	github.com/gocql/gocql v1.7.0 // indirect

     

       
33
       
32
       
 
       
	github.com/gogo/protobuf v1.3.2 // indirect

     

       
34
       
33
       
 
       
	github.com/golang/snappy v0.0.4 // indirect

     

       
35
       
35
       
-
       
	github.com/google/flatbuffers v23.5.26+incompatible // indirect

     

       
36
       
36
       
-
       
	github.com/google/s2a-go v0.1.9 // indirect

     

       
37
       
34
       
 
       
	github.com/google/uuid v1.6.0 // indirect

     

       
38
       
38
       
-
       
	github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect

     

       
39
       
39
       
-
       
	github.com/googleapis/gax-go/v2 v2.14.1 // indirect

     

       
40
       
35
       
 
       
	github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed // indirect

     

       
41
       
36
       
 
       
	github.com/hashicorp/go-cleanhttp v0.5.2 // indirect

     

       
42
       
37
       
 
       
	github.com/hashicorp/go-retryablehttp v0.7.5 // indirect

     
···

       
82
       
77
       
 
       
	github.com/multiformats/go-varint v0.0.7 // indirect

     

       
83
       
78
       
 
       
	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect

     

       
84
       
79
       
 
       
	github.com/opentracing/opentracing-go v1.2.0 // indirect

     

       
80
       
80
       
+
       
	github.com/paulmach/orb v0.11.1 // indirect

     

       
85
       
81
       
 
       
	github.com/pierrec/lz4/v4 v4.1.22 // indirect

     

       
86
       
82
       
 
       
	github.com/polydawn/refmt v0.89.1-0.20221221234430-40501e09de1f // indirect

     

       
87
       
83
       
 
       
	github.com/prometheus/client_model v0.6.1 // indirect

     

       
88
       
84
       
 
       
	github.com/prometheus/common v0.62.0 // indirect

     

       
89
       
85
       
 
       
	github.com/prometheus/procfs v0.15.1 // indirect

     

       
90
       
86
       
 
       
	github.com/russross/blackfriday/v2 v2.1.0 // indirect

     

       
87
       
87
       
+
       
	github.com/segmentio/asm v1.2.0 // indirect

     

       
88
       
88
       
+
       
	github.com/shopspring/decimal v1.4.0 // indirect

     

       
91
       
89
       
 
       
	github.com/spaolacci/murmur3 v1.1.0 // indirect

     

       
92
       
90
       
 
       
	github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e // indirect

     

       
93
       
91
       
 
       
	github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 // indirect

     

       
94
       
94
       
-
       
	github.com/zeebo/xxh3 v1.0.2 // indirect

     

       
95
       
92
       
 
       
	gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b // indirect

     

       
96
       
93
       
 
       
	gitlab.com/yawning/tuplehash v0.0.0-20230713102510-df83abbf9a02 // indirect

     

       
97
       
94
       
 
       
	go.opentelemetry.io/auto/sdk v1.1.0 // indirect

     

       
98
       
98
       
-
       
	go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.60.0 // indirect

     

       
99
       
95
       
 
       
	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.60.0 // indirect

     

       
100
       
96
       
 
       
	go.opentelemetry.io/otel v1.36.0 // indirect

     

       
101
       
97
       
 
       
	go.opentelemetry.io/otel/metric v1.36.0 // indirect

     

       
102
       
102
       
-
       
	go.opentelemetry.io/otel/sdk v1.36.0 // indirect

     

       
103
       
98
       
 
       
	go.opentelemetry.io/otel/trace v1.36.0 // indirect

     

       
104
       
99
       
 
       
	go.uber.org/atomic v1.11.0 // indirect

     

       
105
       
100
       
 
       
	go.uber.org/multierr v1.11.0 // indirect

     

       
106
       
101
       
 
       
	go.uber.org/zap v1.27.0 // indirect

     

       
107
       
102
       
 
       
	golang.org/x/crypto v0.39.0 // indirect

     

       
108
       
103
       
 
       
	golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56 // indirect

     

       
109
       
109
       
-
       
	golang.org/x/mod v0.25.0 // indirect

     

       
110
       
104
       
 
       
	golang.org/x/net v0.41.0 // indirect

     

       
111
       
111
       
-
       
	golang.org/x/oauth2 v0.30.0 // indirect

     

       
112
       
105
       
 
       
	golang.org/x/sync v0.15.0 // indirect

     

       
113
       
106
       
 
       
	golang.org/x/sys v0.33.0 // indirect

     

       
114
       
107
       
 
       
	golang.org/x/text v0.26.0 // indirect

     

       
115
       
108
       
 
       
	golang.org/x/time v0.11.0 // indirect

     

       
116
       
116
       
-
       
	golang.org/x/tools v0.33.0 // indirect

     

       
117
       
109
       
 
       
	golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da // indirect

     

       
118
       
118
       
-
       
	google.golang.org/api v0.232.0 // indirect

     

       
119
       
119
       
-
       
	google.golang.org/genproto v0.0.0-20250303144028-a0af3efb3deb // indirect

     

       
120
       
120
       
-
       
	google.golang.org/genproto/googleapis/api v0.0.0-20250505200425-f936aa4a68b2 // indirect

     

       
121
       
121
       
-
       
	google.golang.org/genproto/googleapis/rpc v0.0.0-20250505200425-f936aa4a68b2 // indirect

     

       
122
       
122
       
-
       
	google.golang.org/grpc v1.72.0 // indirect

     

       
123
       
110
       
 
       
	google.golang.org/protobuf v1.36.6 // indirect

     

       
124
       
111
       
 
       
	gopkg.in/inf.v0 v0.9.1 // indirect

     

       
112
       
112
       
+
       
	gopkg.in/yaml.v3 v3.0.1 // indirect

     

       
125
       
113
       
 
       
	gorm.io/driver/postgres v1.5.7 // indirect

     

       
126
       
114
       
 
       
	gorm.io/gorm v1.30.0 // indirect

     

       
127
       
115
       
 
       
	lukechampine.com/blake3 v1.2.1 // indirect

     

···

       
1
       
1
       
-
       
cel.dev/expr v0.20.0 h1:OunBvVCfvpWlt4dN7zg3FM6TDkzOePe1+foGJ9AXeeI=

     

       
2
       
2
       
-
       
cel.dev/expr v0.20.0/go.mod h1:MrpN08Q+lEBs+bGYdLxxHkZoUSsCp0nSKTs0nTymJgw=

     

       
3
       
3
       
-
       
cloud.google.com/go v0.121.0 h1:pgfwva8nGw7vivjZiRfrmglGWiCJBP+0OmDpenG/Fwg=

     

       
4
       
4
       
-
       
cloud.google.com/go v0.121.0/go.mod h1:rS7Kytwheu/y9buoDmu5EIpMMCI4Mb8ND4aeN4Vwj7Q=

     

       
5
       
5
       
-
       
cloud.google.com/go/auth v0.16.1 h1:XrXauHMd30LhQYVRHLGvJiYeczweKQXZxsTbV9TiguU=

     

       
6
       
6
       
-
       
cloud.google.com/go/auth v0.16.1/go.mod h1:1howDHJ5IETh/LwYs3ZxvlkXF48aSqqJUM+5o02dNOI=

     

       
7
       
7
       
-
       
cloud.google.com/go/auth/oauth2adapt v0.2.8 h1:keo8NaayQZ6wimpNSmW5OPc283g65QNIiLpZnkHRbnc=

     

       
8
       
8
       
-
       
cloud.google.com/go/auth/oauth2adapt v0.2.8/go.mod h1:XQ9y31RkqZCcwJWNSx2Xvric3RrU88hAYYbjDWYDL+c=

     

       
9
       
9
       
-
       
cloud.google.com/go/bigquery v1.69.0 h1:rZvHnjSUs5sHK3F9awiuFk2PeOaB8suqNuim21GbaTc=

     

       
10
       
10
       
-
       
cloud.google.com/go/bigquery v1.69.0/go.mod h1:TdGLquA3h/mGg+McX+GsqG9afAzTAcldMjqhdjHTLew=

     

       
11
       
11
       
-
       
cloud.google.com/go/compute/metadata v0.6.0 h1:A6hENjEsCDtC1k8byVsgwvVcioamEHvZ4j01OwKxG9I=

     

       
12
       
12
       
-
       
cloud.google.com/go/compute/metadata v0.6.0/go.mod h1:FjyFAW1MW0C203CEOMDTu3Dk1FlqW3Rga40jzHL4hfg=

     

       
13
       
13
       
-
       
cloud.google.com/go/datacatalog v1.26.0 h1:eFgygb3DTufTWWUB8ARk+dSuXz+aefNJXTlkWlQcWwE=

     

       
14
       
14
       
-
       
cloud.google.com/go/datacatalog v1.26.0/go.mod h1:bLN2HLBAwB3kLTFT5ZKLHVPj/weNz6bR0c7nYp0LE14=

     

       
15
       
15
       
-
       
cloud.google.com/go/iam v1.5.2 h1:qgFRAGEmd8z6dJ/qyEchAuL9jpswyODjA2lS+w234g8=

     

       
16
       
16
       
-
       
cloud.google.com/go/iam v1.5.2/go.mod h1:SE1vg0N81zQqLzQEwxL2WI6yhetBdbNQuTvIKCSkUHE=

     

       
17
       
17
       
-
       
cloud.google.com/go/longrunning v0.6.7 h1:IGtfDWHhQCgCjwQjV9iiLnUta9LBCo8R9QmAFsS/PrE=

     

       
18
       
18
       
-
       
cloud.google.com/go/longrunning v0.6.7/go.mod h1:EAFV3IZAKmM56TyiE6VAP3VoTzhZzySwI/YI1s/nRsY=

     

       
19
       
19
       
-
       
cloud.google.com/go/monitoring v1.24.0 h1:csSKiCJ+WVRgNkRzzz3BPoGjFhjPY23ZTcaenToJxMM=

     

       
20
       
20
       
-
       
cloud.google.com/go/monitoring v1.24.0/go.mod h1:Bd1PRK5bmQBQNnuGwHBfUamAV1ys9049oEPHnn4pcsc=

     

       
21
       
21
       
-
       
cloud.google.com/go/storage v1.53.0 h1:gg0ERZwL17pJ+Cz3cD2qS60w1WMDnwcm5YPAIQBHUAw=

     

       
22
       
22
       
-
       
cloud.google.com/go/storage v1.53.0/go.mod h1:7/eO2a/srr9ImZW9k5uufcNahT2+fPb8w5it1i5boaA=

     

       
23
       
1
       
 
       
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=

     

       
24
       
24
       
-
       
github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0 h1:ErKg/3iS1AKcTkf3yixlZ54f9U1rljCkQyEXWUnIUxc=

     

       
25
       
25
       
-
       
github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0/go.mod h1:yAZHSGnqScoU556rBOVkwLze6WP5N+U11RHuWaGVxwY=

     

       
26
       
26
       
-
       
github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/metric v0.51.0 h1:fYE9p3esPxA/C0rQ0AHhP0drtPXDRhaWiwg1DPqO7IU=

     

       
27
       
27
       
-
       
github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/metric v0.51.0/go.mod h1:BnBReJLvVYx2CS/UHOgVz2BXKXD9wsQPxZug20nZhd0=

     

       
28
       
28
       
-
       
github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/resourcemapping v0.51.0 h1:6/0iUd0xrnX7qt+mLNRwg5c0PGv8wpE8K90ryANQwMI=

     

       
29
       
29
       
-
       
github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/resourcemapping v0.51.0/go.mod h1:otE2jQekW/PqXk1Awf5lmfokJx4uwuqcj1ab5SpGeW0=

     

       
2
       
2
       
+
       
github.com/ClickHouse/ch-go v0.66.1 h1:LQHFslfVYZsISOY0dnOYOXGkOUvpv376CCm8g7W74A4=

     

       
3
       
3
       
+
       
github.com/ClickHouse/ch-go v0.66.1/go.mod h1:NEYcg3aOFv2EmTJfo4m2WF7sHB/YFbLUuIWv9iq76xY=

     

       
4
       
4
       
+
       
github.com/ClickHouse/clickhouse-go v1.5.4 h1:cKjXeYLNWVJIx2J1K6H2CqyRmfwVJVY1OV1coaaFcI0=

     

       
5
       
5
       
+
       
github.com/ClickHouse/clickhouse-go v1.5.4/go.mod h1:EaI/sW7Azgz9UATzd5ZdZHRUhHgv5+JMS9NSr2smCJI=

     

       
6
       
6
       
+
       
github.com/ClickHouse/clickhouse-go/v2 v2.37.2 h1:wRLNKoynvHQEN4znnVHNLaYnrqVc9sGJmGYg+GGCfto=

     

       
7
       
7
       
+
       
github.com/ClickHouse/clickhouse-go/v2 v2.37.2/go.mod h1:pH2zrBGp5Y438DMwAxXMm1neSXPPjSI7tD4MURVULw8=

     

       
30
       
8
       
 
       
github.com/RussellLuo/slidingwindow v0.0.0-20200528002341-535bb99d338b h1:5/++qT1/z812ZqBvqQt6ToRswSuPZ/B33m6xVHRzADU=

     

       
31
       
9
       
 
       
github.com/RussellLuo/slidingwindow v0.0.0-20200528002341-535bb99d338b/go.mod h1:4+EPqMRApwwE/6yo6CxiHoSnBzjRr3jsqer7frxP8y4=

     

       
32
       
10
       
 
       
github.com/alexbrainman/goissue34681 v0.0.0-20191006012335-3fc7a47baff5 h1:iW0a5ljuFxkLGPNem5Ui+KBjFJzKg4Fv2fnxe4dvzpM=

     

       
33
       
11
       
 
       
github.com/alexbrainman/goissue34681 v0.0.0-20191006012335-3fc7a47baff5/go.mod h1:Y2QMoi1vgtOIfc+6DhrMOGkLoGzqSV2rKp4Sm+opsyA=

     

       
34
       
34
       
-
       
github.com/apache/arrow/go/v15 v15.0.2 h1:60IliRbiyTWCWjERBCkO1W4Qun9svcYoZrSLcyOsMLE=

     

       
35
       
35
       
-
       
github.com/apache/arrow/go/v15 v15.0.2/go.mod h1:DGXsR3ajT524njufqf95822i+KTh+yea1jass9YXgjA=

     

       
12
       
12
       
+
       
github.com/andybalholm/brotli v1.1.1 h1:PR2pgnyFznKEugtsUo0xLdDop5SKXd5Qf5ysW+7XdTA=

     

       
13
       
13
       
+
       
github.com/andybalholm/brotli v1.1.1/go.mod h1:05ib4cKhjx3OQYUY22hTVd34Bc8upXjOLL2rKwwZBoA=

     

       
36
       
14
       
 
       
github.com/araddon/dateparse v0.0.0-20210429162001-6b43995a97de h1:FxWPpzIjnTlhPwqqXc4/vE0f7GvRjuAsbW+HOIe8KnA=

     

       
37
       
15
       
 
       
github.com/araddon/dateparse v0.0.0-20210429162001-6b43995a97de/go.mod h1:DCaWoUhZrYW9p1lxo/cm8EmUOOzAPSEZNGF2DK1dJgw=

     

       
38
       
16
       
 
       
github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=

     
···

       
42
       
20
       
 
       
github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=

     

       
43
       
21
       
 
       
github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932 h1:mXoPYz/Ul5HYEDvkta6I8/rnYM5gSdSV2tJ6XbZuEtY=

     

       
44
       
22
       
 
       
github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932/go.mod h1:NOuUCSz6Q9T7+igc/hlvDOUdtWKryOrtFyIVABv/p7k=

     

       
23
       
23
       
+
       
github.com/bkaradzic/go-lz4 v1.0.0 h1:RXc4wYsyz985CkXXeX04y4VnZFGG8Rd43pRaHsOXAKk=

     

       
24
       
24
       
+
       
github.com/bkaradzic/go-lz4 v1.0.0/go.mod h1:0YdlkowM3VswSROI7qDxhRvJ3sLhlFrRRwjwegp5jy4=

     

       
45
       
25
       
 
       
github.com/bluesky-social/indigo v0.0.0-20250626183556-5641d3c27325 h1:Bftt2EcoLZK2Z2m12Ih5QqbReX8j29hbf4zJU/FKzaY=

     

       
46
       
26
       
 
       
github.com/bluesky-social/indigo v0.0.0-20250626183556-5641d3c27325/go.mod h1:8FlFpF5cIq3DQG0kEHqyTkPV/5MDQoaWLcVwza5ZPJU=

     

       
47
       
27
       
 
       
github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869 h1:DDGfHa7BWjL4YnC6+E63dPcxHo2sUxDIu8g3QgEJdRY=

     
···

       
50
       
30
       
 
       
github.com/carlmjohnson/versioninfo v0.22.5/go.mod h1:QT9mph3wcVfISUKd0i9sZfVrPviHuSF+cUtLjm2WSf8=

     

       
51
       
31
       
 
       
github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=

     

       
52
       
32
       
 
       
github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=

     

       
53
       
53
       
-
       
github.com/cncf/xds/go v0.0.0-20250121191232-2f005788dc42 h1:Om6kYQYDUk5wWbT0t0q6pvyM49i9XZAv9dDrkDA7gjk=

     

       
54
       
54
       
-
       
github.com/cncf/xds/go v0.0.0-20250121191232-2f005788dc42/go.mod h1:W+zGtBO5Y1IgJhy4+A9GOqVhqLpfZi+vwmdNXUehLA8=

     

       
33
       
33
       
+
       
github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58 h1:F1EaeKL/ta07PY/k9Os/UFtwERei2/XzGemhpGnBKNg=

     

       
34
       
34
       
+
       
github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58/go.mod h1:EOBUe0h4xcZ5GoxqC5SDxFQ8gwyZPKQoEzownBlhI80=

     

       
55
       
35
       
 
       
github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=

     

       
56
       
36
       
 
       
github.com/cpuguy83/go-md2man/v2 v2.0.3 h1:qMCsGGgs+MAzDFyp9LpAe1Lqy/fY/qCovCm0qnXZOBM=

     

       
57
       
37
       
 
       
github.com/cpuguy83/go-md2man/v2 v2.0.3/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=

     
···

       
62
       
42
       
 
       
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

     

       
63
       
43
       
 
       
github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0 h1:8UrgZ3GkP4i/CLijOJx79Yu+etlyjdBU4sfcs2WYQMs=

     

       
64
       
44
       
 
       
github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0/go.mod h1:v57UDF4pDQJcEfFUCRop3lJL149eHGSe9Jvczhzjo/0=

     

       
65
       
65
       
-
       
github.com/envoyproxy/go-control-plane v0.13.4 h1:zEqyPVyku6IvWCFwux4x9RxkLOMUL+1vC9xUFv5l2/M=

     

       
66
       
66
       
-
       
github.com/envoyproxy/go-control-plane/envoy v1.32.4 h1:jb83lalDRZSpPWW2Z7Mck/8kXZ5CQAFYVjQcdVIr83A=

     

       
67
       
67
       
-
       
github.com/envoyproxy/go-control-plane/envoy v1.32.4/go.mod h1:Gzjc5k8JcJswLjAx1Zm+wSYE20UrLtt7JZMWiWQXQEw=

     

       
68
       
68
       
-
       
github.com/envoyproxy/protoc-gen-validate v1.2.1 h1:DEo3O99U8j4hBFwbJfrz9VtgcDfUKS7KJ7spH3d86P8=

     

       
69
       
69
       
-
       
github.com/envoyproxy/protoc-gen-validate v1.2.1/go.mod h1:d/C80l/jxXLdfEIhX1W2TmLfsJ31lvEjwamM4DxlWXU=

     

       
70
       
45
       
 
       
github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=

     

       
71
       
46
       
 
       
github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=

     

       
72
       
47
       
 
       
github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=

     

       
73
       
48
       
 
       
github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=

     

       
74
       
74
       
-
       
github.com/go-jose/go-jose/v4 v4.0.4 h1:VsjPI33J0SB9vQM6PLmNjoHqMQNGPiZ0rHL7Ni7Q6/E=

     

       
75
       
75
       
-
       
github.com/go-jose/go-jose/v4 v4.0.4/go.mod h1:NKb5HO1EZccyMpiZNbdUw/14tiXNyUJh188dfnMCAfc=

     

       
49
       
49
       
+
       
github.com/go-faster/city v1.0.1 h1:4WAxSZ3V2Ws4QRDrscLEDcibJY8uf41H6AhXDrNDcGw=

     

       
50
       
50
       
+
       
github.com/go-faster/city v1.0.1/go.mod h1:jKcUJId49qdW3L1qKHH/3wPeUstCVpVSXTM6vO3VcTw=

     

       
51
       
51
       
+
       
github.com/go-faster/errors v0.7.1 h1:MkJTnDoEdi9pDabt1dpWf7AA8/BaSYZqibYyhZ20AYg=

     

       
52
       
52
       
+
       
github.com/go-faster/errors v0.7.1/go.mod h1:5ySTjWFiphBs07IKuiL69nxdfd5+fzh1u7FPGZP2quo=

     

       
76
       
53
       
 
       
github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=

     

       
77
       
54
       
 
       
github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=

     

       
78
       
55
       
 
       
github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=

     
···

       
80
       
57
       
 
       
github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=

     

       
81
       
58
       
 
       
github.com/go-redis/redis v6.15.9+incompatible h1:K0pv1D7EQUjfyoMql+r/jZqCLizCGKFlFgcHWWmHQjg=

     

       
82
       
59
       
 
       
github.com/go-redis/redis v6.15.9+incompatible/go.mod h1:NAIEuMOZ/fxfXJIrKDQDz8wamY7mA7PouImQ2Jvg6kA=

     

       
60
       
60
       
+
       
github.com/go-sql-driver/mysql v1.4.0/go.mod h1:zAC/RDZ24gD3HViQzih4MyKcchzm+sOG5ZlKdlhCg5w=

     

       
83
       
61
       
 
       
github.com/go-yaml/yaml v2.1.0+incompatible/go.mod h1:w2MrLa16VYP0jy6N7M5kHaCkaLENm+P+Tv+MfurjSw0=

     

       
84
       
84
       
-
       
github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU=

     

       
85
       
85
       
-
       
github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=

     

       
86
       
62
       
 
       
github.com/gocql/gocql v1.7.0 h1:O+7U7/1gSN7QTEAaMEsJc1Oq2QHXvCWoF3DFK9HDHus=

     

       
87
       
63
       
 
       
github.com/gocql/gocql v1.7.0/go.mod h1:vnlvXyFZeLBF0Wy+RS8hrOdbn0UWsWtdg07XJnFxZ+4=

     

       
88
       
64
       
 
       
github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=

     

       
89
       
65
       
 
       
github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=

     

       
90
       
90
       
-
       
github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=

     

       
91
       
91
       
-
       
github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=

     

       
66
       
66
       
+
       
github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=

     

       
67
       
67
       
+
       
github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=

     

       
92
       
68
       
 
       
github.com/golang/snappy v0.0.3/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=

     

       
93
       
69
       
 
       
github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=

     

       
94
       
70
       
 
       
github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=

     

       
95
       
95
       
-
       
github.com/google/flatbuffers v23.5.26+incompatible h1:M9dgRyhJemaM4Sw8+66GHBu8ioaQmyPLg1b8VwK5WJg=

     

       
96
       
96
       
-
       
github.com/google/flatbuffers v23.5.26+incompatible/go.mod h1:1AeVuKshWv4vARoZatz6mlQ0JxURH0Kv5+zNeJKJCa8=

     

       
71
       
71
       
+
       
github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=

     

       
72
       
72
       
+
       
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=

     

       
97
       
73
       
 
       
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=

     

       
98
       
74
       
 
       
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=

     

       
99
       
75
       
 
       
github.com/google/gopacket v1.1.19 h1:ves8RnFZPGiFnTS0uPQStjwru6uO6h+nlr9j6fL7kF8=

     

       
100
       
76
       
 
       
github.com/google/gopacket v1.1.19/go.mod h1:iJ8V8n6KS+z2U1A8pUwu8bW5SyEMkXJB8Yo/Vo+TKTo=

     

       
101
       
101
       
-
       
github.com/google/martian/v3 v3.3.3 h1:DIhPTQrbPkgs2yJYdXU/eNACCG5DVQjySNRNlflZ9Fc=

     

       
102
       
102
       
-
       
github.com/google/martian/v3 v3.3.3/go.mod h1:iEPrYcgCF7jA9OtScMFQyAlZZ4YXTKEtJ1E6RWzmBA0=

     

       
103
       
77
       
 
       
github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=

     

       
104
       
104
       
-
       
github.com/google/s2a-go v0.1.9 h1:LGD7gtMgezd8a/Xak7mEWL0PjoTQFvpRudN895yqKW0=

     

       
105
       
105
       
-
       
github.com/google/s2a-go v0.1.9/go.mod h1:YA0Ei2ZQL3acow2O62kdp9UlnvMmU7kA6Eutn0dXayM=

     

       
106
       
78
       
 
       
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=

     

       
107
       
79
       
 
       
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=

     

       
108
       
108
       
-
       
github.com/googleapis/enterprise-certificate-proxy v0.3.6 h1:GW/XbdyBFQ8Qe+YAmFU9uHLo7OnF5tL52HFAgMmyrf4=

     

       
109
       
109
       
-
       
github.com/googleapis/enterprise-certificate-proxy v0.3.6/go.mod h1:MkHOF77EYAE7qfSuSS9PU6g4Nt4e11cnsDUowfwewLA=

     

       
110
       
110
       
-
       
github.com/googleapis/gax-go/v2 v2.14.1 h1:hb0FFeiPaQskmvakKu5EbCbpntQn48jyHuvrkurSS/Q=

     

       
111
       
111
       
-
       
github.com/googleapis/gax-go/v2 v2.14.1/go.mod h1:Hb/NubMaVM88SrNkvl8X/o8XWwDJEPqouaLeN2IUxoA=

     

       
112
       
80
       
 
       
github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1 h1:EGx4pi6eqNxGaHF6qqu48+N2wcFQ5qg5FXgOdqsJ5d8=

     

       
113
       
81
       
 
       
github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=

     

       
114
       
82
       
 
       
github.com/gorilla/websocket v1.5.1 h1:gmztn0JnHVt9JZquRuzLw3g4wouNVzKL15iLr/zn/QY=

     
···

       
209
       
177
       
 
       
github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=

     

       
210
       
178
       
 
       
github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=

     

       
211
       
179
       
 
       
github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=

     

       
180
       
180
       
+
       
github.com/jmoiron/sqlx v1.2.0/go.mod h1:1FEQNm3xlJgrMD+FBdI9+xvCksHtbpVBBw5dYhBSsks=

     

       
212
       
181
       
 
       
github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=

     

       
213
       
182
       
 
       
github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=

     

       
214
       
183
       
 
       
github.com/jtolds/gls v4.20.0+incompatible h1:xdiiI2gbIgH/gLH7ADydsJ1uDOEzR8yvV7C0MuV77Wo=

     

       
215
       
184
       
 
       
github.com/jtolds/gls v4.20.0+incompatible/go.mod h1:QJZ7F/aHp+rZTRtaJ1ow/lLfFfVYBRgL+9YlvaHOwJU=

     

       
216
       
185
       
 
       
github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=

     

       
217
       
186
       
 
       
github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=

     

       
187
       
187
       
+
       
github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk=

     

       
218
       
188
       
 
       
github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=

     

       
219
       
189
       
 
       
github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=

     

       
220
       
190
       
 
       
github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM=

     
···

       
230
       
200
       
 
       
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=

     

       
231
       
201
       
 
       
github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc=

     

       
232
       
202
       
 
       
github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=

     

       
203
       
203
       
+
       
github.com/lib/pq v1.0.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=

     

       
233
       
204
       
 
       
github.com/libp2p/go-buffer-pool v0.1.0 h1:oK4mSFcQz7cTQIfqbe4MIj9gLW+mnanjyFtc6cdF0Y8=

     

       
234
       
205
       
 
       
github.com/libp2p/go-buffer-pool v0.1.0/go.mod h1:N+vh8gMqimBzdKkSMVuydVDq+UV5QTWy5HSiZacSbPg=

     

       
235
       
206
       
 
       
github.com/libp2p/go-cidranger v1.1.0 h1:ewPN8EZ0dd1LSnrtuwd4709PXVcITVeuwbag38yPW7c=

     
···

       
252
       
223
       
 
       
github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=

     

       
253
       
224
       
 
       
github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=

     

       
254
       
225
       
 
       
github.com/mattn/go-runewidth v0.0.10/go.mod h1:RAqKPSqVFrSLVXbA8x7dzmKdmGzieGRCM46jaSJTDAk=

     

       
226
       
226
       
+
       
github.com/mattn/go-sqlite3 v1.9.0/go.mod h1:FPy6KqzDD04eiIsT53CuJW3U88zkxoIYsOqkbpncsNc=

     

       
255
       
227
       
 
       
github.com/mattn/go-sqlite3 v1.14.22 h1:2gZY6PC6kBnID23Tichd1K+Z0oS6nE/XwU+Vz/5o4kU=

     

       
256
       
228
       
 
       
github.com/mattn/go-sqlite3 v1.14.22/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=

     

       
257
       
229
       
 
       
github.com/miekg/dns v1.1.50 h1:DQUfb9uc6smULcREF09Uc+/Gd46YWqJd5DbpPE9xkcA=

     

       
258
       
230
       
 
       
github.com/miekg/dns v1.1.50/go.mod h1:e3IlAVfNqAllflbibAZEWOXOQ+Ynzk/dDozDxY7XnME=

     

       
259
       
231
       
 
       
github.com/minio/sha256-simd v1.0.1 h1:6kaan5IFmwTNynnKKpDHe6FWHohJOHhCPchzK49dzMM=

     

       
260
       
232
       
 
       
github.com/minio/sha256-simd v1.0.1/go.mod h1:Pz6AKMiUdngCLpeTL/RJY1M9rUuPMYujV5xJjtbRSN8=

     

       
233
       
233
       
+
       
github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe/go.mod h1:wL8QJuTMNUDYhXwkmfOly8iTdp5TEcJFWZD2D7SIkUc=

     

       
261
       
234
       
 
       
github.com/mr-tron/base58 v1.2.0 h1:T/HDJBh4ZCPbU39/+c3rRvE0uKBQlU27+QI8LJ4t64o=

     

       
262
       
235
       
 
       
github.com/mr-tron/base58 v1.2.0/go.mod h1:BinMc/sQntlIE1frQmRFPUoPA1Zkr8VRgBdjWI2mNwc=

     

       
263
       
236
       
 
       
github.com/multiformats/go-base32 v0.1.0 h1:pVx9xoSPqEIQG8o+UbAe7DNi51oej1NtK+aGkbLYxPE=

     
···

       
284
       
257
       
 
       
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=

     

       
285
       
258
       
 
       
github.com/opentracing/opentracing-go v1.2.0 h1:uEJPy/1a5RIPAJ0Ov+OIO8OxWu77jEv+1B0VhjKrZUs=

     

       
286
       
259
       
 
       
github.com/opentracing/opentracing-go v1.2.0/go.mod h1:GxEUsuufX4nBwe+T+Wl9TAgYrxe9dPLANfrWvHYVTgc=

     

       
260
       
260
       
+
       
github.com/paulmach/orb v0.11.1 h1:3koVegMC4X/WeiXYz9iswopaTwMem53NzTJuTF20JzU=

     

       
261
       
261
       
+
       
github.com/paulmach/orb v0.11.1/go.mod h1:5mULz1xQfs3bmQm63QEJA6lNGujuRafwA5S/EnuLaLU=

     

       
262
       
262
       
+
       
github.com/paulmach/protoscan v0.2.1/go.mod h1:SpcSwydNLrxUGSDvXvO0P7g7AuhJ7lcKfDlhJCDw2gY=

     

       
287
       
263
       
 
       
github.com/petar/GoLLRB v0.0.0-20210522233825-ae3b015fd3e9 h1:1/WtZae0yGtPq+TI6+Tv1WTxkukpXeMlviSxvL7SRgk=

     

       
288
       
264
       
 
       
github.com/petar/GoLLRB v0.0.0-20210522233825-ae3b015fd3e9/go.mod h1:x3N5drFsm2uilKKuuYo6LdyD8vZAW55sH/9w+pbo1sw=

     

       
265
       
265
       
+
       
github.com/pierrec/lz4 v2.0.5+incompatible h1:2xWsjqPFWcplujydGg4WmhC/6fZqK42wMM8aXeqhl0I=

     

       
266
       
266
       
+
       
github.com/pierrec/lz4 v2.0.5+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=

     

       
289
       
267
       
 
       
github.com/pierrec/lz4/v4 v4.1.22 h1:cKFw6uJDK+/gfw5BcDL0JL5aBsAFdsIT18eRtLj7VIU=

     

       
290
       
268
       
 
       
github.com/pierrec/lz4/v4 v4.1.22/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4=

     

       
291
       
269
       
 
       
github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=

     

       
292
       
292
       
-
       
github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10 h1:GFCKgmp0tecUJ0sJuv4pzYCqS9+RGSn52M3FUwPs+uo=

     

       
293
       
293
       
-
       
github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10/go.mod h1:t/avpk3KcrXxUnYOhZhMXJlSEyie6gQbtLq5NM3loB8=

     

       
270
       
270
       
+
       
github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=

     

       
294
       
271
       
 
       
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=

     

       
295
       
272
       
 
       
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=

     

       
296
       
273
       
 
       
github.com/polydawn/refmt v0.89.1-0.20221221234430-40501e09de1f h1:VXTQfuJj9vKR4TCkEuWIckKvdHFeJH/huIFJ9/cXOB0=

     
···

       
311
       
288
       
 
       
github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk=

     

       
312
       
289
       
 
       
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=

     

       
313
       
290
       
 
       
github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4/go.mod h1:C1a7PQSMz9NShzorzCiG2fk9+xuCgLkPeCvMHYR2OWg=

     

       
291
       
291
       
+
       
github.com/segmentio/asm v1.2.0 h1:9BQrFxC+YOHJlTlHGkTrFWf59nbL3XnCoFLTwDCI7ys=

     

       
292
       
292
       
+
       
github.com/segmentio/asm v1.2.0/go.mod h1:BqMnlJP91P8d+4ibuonYZw9mfnzI9HfxselHZr5aAcs=

     

       
293
       
293
       
+
       
github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=

     

       
294
       
294
       
+
       
github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=

     

       
314
       
295
       
 
       
github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=

     

       
315
       
296
       
 
       
github.com/smartystreets/assertions v1.2.0 h1:42S6lae5dvLc7BrLu/0ugRtcFVjoJNMC/N3yZFZkDFs=

     

       
316
       
297
       
 
       
github.com/smartystreets/assertions v1.2.0/go.mod h1:tcbTF8ujkAEcZ8TElKY+i30BzYlVhC/LOxJk7iOWnoo=

     
···

       
318
       
299
       
 
       
github.com/smartystreets/goconvey v1.7.2/go.mod h1:Vw0tHAZW6lzCRk3xgdin6fKYcG+G3Pg9vgXWeJpQFMM=

     

       
319
       
300
       
 
       
github.com/spaolacci/murmur3 v1.1.0 h1:7c1g84S4BPRrfL5Xrdp6fOJ206sU9y293DDHaoy0bLI=

     

       
320
       
301
       
 
       
github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=

     

       
321
       
321
       
-
       
github.com/spiffe/go-spiffe/v2 v2.5.0 h1:N2I01KCUkv1FAjZXJMwh95KK1ZIQLYbPfhaxw8WS0hE=

     

       
322
       
322
       
-
       
github.com/spiffe/go-spiffe/v2 v2.5.0/go.mod h1:P+NxobPc6wXhVtINNtFjNWGBTreew1GBUCwT2wPmb7g=

     

       
323
       
302
       
 
       
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=

     

       
324
       
303
       
 
       
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=

     

       
325
       
304
       
 
       
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=

     

       
326
       
305
       
 
       
github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=

     

       
306
       
306
       
+
       
github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

     

       
327
       
307
       
 
       
github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

     

       
328
       
308
       
 
       
github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=

     

       
329
       
309
       
 
       
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=

     

       
310
       
310
       
+
       
github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=

     

       
330
       
311
       
 
       
github.com/urfave/cli v1.22.10/go.mod h1:Gos4lmkARVdJ6EkW0WaNv/tZAAMe9V7XWyB60NtXRu0=

     

       
331
       
312
       
 
       
github.com/urfave/cli/v2 v2.25.7 h1:VAzn5oq403l5pHjc4OhD54+XGO9cdKVL/7lDjF+iKUs=

     

       
332
       
313
       
 
       
github.com/urfave/cli/v2 v2.25.7/go.mod h1:8qnjx1vcq5s2/wpsqoZFndg2CE5tNFyrTvS6SinrnYQ=

     
···

       
338
       
319
       
 
       
github.com/whyrusleeping/cbor v0.0.0-20171005072247-63513f603b11/go.mod h1:Wlo/SzPmxVp6vXpGt/zaXhHH0fn4IxgqZc82aKg6bpQ=

     

       
339
       
320
       
 
       
github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e h1:28X54ciEwwUxyHn9yrZfl5ojgF4CBNLWX7LR0rvBkf4=

     

       
340
       
321
       
 
       
github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e/go.mod h1:pM99HXyEbSQHcosHc0iW7YFmwnscr+t9Te4ibko05so=

     

       
322
       
322
       
+
       
github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=

     

       
323
       
323
       
+
       
github.com/xdg-go/scram v1.1.1/go.mod h1:RaEWvsqvNKKvBPvcKeFjrG2cJqOkHTiyTpzz23ni57g=

     

       
324
       
324
       
+
       
github.com/xdg-go/stringprep v1.0.3/go.mod h1:W3f5j4i+9rC0kuIEJL0ky1VpHXQU3ocBgklLGvcBnW8=

     

       
341
       
325
       
 
       
github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 h1:bAn7/zixMGCfxrRTfdpNzjtPYqr8smhKouy9mxVdGPU=

     

       
342
       
326
       
 
       
github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673/go.mod h1:N3UwUGtsrSj3ccvlPHLoLsHnpR27oXr4ZE984MbSER8=

     

       
327
       
327
       
+
       
github.com/xyproto/randomstring v1.0.5 h1:YtlWPoRdgMu3NZtP45drfy1GKoojuR7hmRcnhZqKjWU=

     

       
328
       
328
       
+
       
github.com/xyproto/randomstring v1.0.5/go.mod h1:rgmS5DeNXLivK7YprL0pY+lTuhNQW3iGxZ18UQApw/E=

     

       
329
       
329
       
+
       
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=

     

       
343
       
330
       
 
       
github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

     

       
344
       
331
       
 
       
github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

     

       
345
       
332
       
 
       
github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=

     

       
346
       
346
       
-
       
github.com/zeebo/assert v1.3.0 h1:g7C04CbJuIDKNPFHmsk4hwZDO5O+kntRxzaUoNXj+IQ=

     

       
347
       
347
       
-
       
github.com/zeebo/assert v1.3.0/go.mod h1:Pq9JiuJQpG8JLJdtkwrJESF0Foym2/D9XMU5ciN/wJ0=

     

       
348
       
348
       
-
       
github.com/zeebo/errs v1.4.0 h1:XNdoD/RRMKP7HD0UhJnIzUy74ISdGGxURlYG8HSWSfM=

     

       
349
       
349
       
-
       
github.com/zeebo/errs v1.4.0/go.mod h1:sgbWHsvVuTPHcqJJGQ1WhI5KbWlHYz+2+2C/LSEtCw4=

     

       
350
       
350
       
-
       
github.com/zeebo/xxh3 v1.0.2 h1:xZmwmqxHZA8AI603jOQ0tMqmBr9lPeFwGg6d+xy9DC0=

     

       
351
       
351
       
-
       
github.com/zeebo/xxh3 v1.0.2/go.mod h1:5NWz9Sef7zIDm2JHfFlcQvNekmcEl9ekUZQQKCYaDcA=

     

       
352
       
333
       
 
       
gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b h1:CzigHMRySiX3drau9C6Q5CAbNIApmLdat5jPMqChvDA=

     

       
353
       
334
       
 
       
gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b/go.mod h1:/y/V339mxv2sZmYYR64O07VuCpdNZqCTwO8ZcouTMI8=

     

       
354
       
335
       
 
       
gitlab.com/yawning/tuplehash v0.0.0-20230713102510-df83abbf9a02 h1:qwDnMxjkyLmAFgcfgTnfJrmYKWhHnci3GjDqcZp1M3Q=

     

       
355
       
336
       
 
       
gitlab.com/yawning/tuplehash v0.0.0-20230713102510-df83abbf9a02/go.mod h1:JTnUj0mpYiAsuZLmKjTx/ex3AtMowcCgnE7YNyCEP0I=

     

       
337
       
337
       
+
       
go.mongodb.org/mongo-driver v1.11.4/go.mod h1:PTSz5yu21bkT/wXpkS7WR5f0ddqw5quethTUn9WM+2g=

     

       
356
       
338
       
 
       
go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=

     

       
357
       
339
       
 
       
go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A=

     

       
358
       
358
       
-
       
go.opentelemetry.io/contrib/detectors/gcp v1.35.0 h1:bGvFt68+KTiAKFlacHW6AhA56GF2rS0bdD3aJYEnmzA=

     

       
359
       
359
       
-
       
go.opentelemetry.io/contrib/detectors/gcp v1.35.0/go.mod h1:qGWP8/+ILwMRIUf9uIVLloR1uo5ZYAslM4O6OqUi1DA=

     

       
360
       
360
       
-
       
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.60.0 h1:x7wzEgXfnzJcHDwStJT+mxOz4etr2EcexjqhBvmoakw=

     

       
361
       
361
       
-
       
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.60.0/go.mod h1:rg+RlpR5dKwaS95IyyZqj5Wd4E13lk/msnTS0Xl9lJM=

     

       
362
       
340
       
 
       
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.60.0 h1:sbiXRNDSWJOTobXh5HyQKjq6wUC5tNybqjIqDpAY4CU=

     

       
363
       
341
       
 
       
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.60.0/go.mod h1:69uWxva0WgAA/4bu2Yy70SLDBwZXuQ6PbBpbsa5iZrQ=

     

       
364
       
342
       
 
       
go.opentelemetry.io/otel v1.36.0 h1:UumtzIklRBY6cI/lllNZlALOF5nNIzJVb16APdvgTXg=

     
···

       
391
       
369
       
 
       
golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=

     

       
392
       
370
       
 
       
golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=

     

       
393
       
371
       
 
       
golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=

     

       
372
       
372
       
+
       
golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=

     

       
394
       
373
       
 
       
golang.org/x/crypto v0.39.0 h1:SHs+kF4LP+f+p14esP5jAoDpHU8Gu/v9lFRK6IT5imM=

     

       
395
       
374
       
 
       
golang.org/x/crypto v0.39.0/go.mod h1:L+Xg3Wf6HoL4Bn4238Z6ft6KfEpN0tJGo53AAPC632U=

     

       
396
       
375
       
 
       
golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56 h1:2dVuKD2vS7b0QIHQbpyTISPd0LeHDbnYEryqj5Q1ug8=

     
···

       
408
       
387
       
 
       
golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=

     

       
409
       
388
       
 
       
golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=

     

       
410
       
389
       
 
       
golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM=

     

       
390
       
390
       
+
       
golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=

     

       
411
       
391
       
 
       
golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw=

     

       
412
       
392
       
 
       
golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA=

     

       
413
       
413
       
-
       
golang.org/x/oauth2 v0.30.0 h1:dnDm7JmhM45NNpd8FDDeLhK6FwqbOf4MLCM9zb1BOHI=

     

       
414
       
414
       
-
       
golang.org/x/oauth2 v0.30.0/go.mod h1:B++QgG3ZKulg6sRPGD/mqlHQs5rB3Ml9erfeDY7xKlU=

     

       
415
       
393
       
 
       
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=

     

       
416
       
394
       
 
       
golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=

     

       
417
       
395
       
 
       
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=

     
···

       
423
       
401
       
 
       
golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       
424
       
402
       
 
       
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       
425
       
403
       
 
       
golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       
404
       
404
       
+
       
golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       
426
       
405
       
 
       
golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       
406
       
406
       
+
       
golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       
427
       
407
       
 
       
golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       
428
       
408
       
 
       
golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       
429
       
409
       
 
       
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     
···

       
432
       
412
       
 
       
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=

     

       
433
       
413
       
 
       
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=

     

       
434
       
414
       
 
       
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=

     

       
415
       
415
       
+
       
golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=

     

       
416
       
416
       
+
       
golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=

     

       
435
       
417
       
 
       
golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=

     

       
436
       
418
       
 
       
golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=

     

       
437
       
419
       
 
       
golang.org/x/time v0.11.0 h1:/bpjEDfN9tkoN/ryeYHnv5hcMlc8ncjMcM4XBk5NWV0=

     
···

       
454
       
436
       
 
       
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

     

       
455
       
437
       
 
       
golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da h1:noIWHXmPHxILtqtCOPIhSt0ABwskkZKjD3bXGnZGpNY=

     

       
456
       
438
       
 
       
golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da/go.mod h1:NDW/Ps6MPRej6fsCIbMTohpP40sJ/P/vI1MoTEGwX90=

     

       
457
       
457
       
-
       
gonum.org/v1/gonum v0.12.0 h1:xKuo6hzt+gMav00meVPUlXwSdoEJP46BR+wdxQEFK2o=

     

       
458
       
458
       
-
       
gonum.org/v1/gonum v0.12.0/go.mod h1:73TDxJfAAHeA8Mk9mf8NlIppyhQNo5GLTcYeqgo2lvY=

     

       
459
       
459
       
-
       
google.golang.org/api v0.232.0 h1:qGnmaIMf7KcuwHOlF3mERVzChloDYwRfOJOrHt8YC3I=

     

       
460
       
460
       
-
       
google.golang.org/api v0.232.0/go.mod h1:p9QCfBWZk1IJETUdbTKloR5ToFdKbYh2fkjsUL6vNoY=

     

       
461
       
461
       
-
       
google.golang.org/genproto v0.0.0-20250303144028-a0af3efb3deb h1:ITgPrl429bc6+2ZraNSzMDk3I95nmQln2fuPstKwFDE=

     

       
462
       
462
       
-
       
google.golang.org/genproto v0.0.0-20250303144028-a0af3efb3deb/go.mod h1:sAo5UzpjUwgFBCzupwhcLcxHVDK7vG5IqI30YnwX2eE=

     

       
463
       
463
       
-
       
google.golang.org/genproto/googleapis/api v0.0.0-20250505200425-f936aa4a68b2 h1:vPV0tzlsK6EzEDHNNH5sa7Hs9bd7iXR7B1tSiPepkV0=

     

       
464
       
464
       
-
       
google.golang.org/genproto/googleapis/api v0.0.0-20250505200425-f936aa4a68b2/go.mod h1:pKLAc5OolXC3ViWGI62vvC0n10CpwAtRcTNCFwTKBEw=

     

       
465
       
465
       
-
       
google.golang.org/genproto/googleapis/rpc v0.0.0-20250505200425-f936aa4a68b2 h1:IqsN8hx+lWLqlN+Sc3DoMy/watjofWiU8sRFgQ8fhKM=

     

       
466
       
466
       
-
       
google.golang.org/genproto/googleapis/rpc v0.0.0-20250505200425-f936aa4a68b2/go.mod h1:qQ0YXyHHx3XkvlzUtpXDkS29lDSafHMZBAZDc03LQ3A=

     

       
467
       
467
       
-
       
google.golang.org/grpc v1.72.0 h1:S7UkcVa60b5AAQTaO6ZKamFp1zMZSU0fGDK2WZLbBnM=

     

       
468
       
468
       
-
       
google.golang.org/grpc v1.72.0/go.mod h1:wH5Aktxcg25y1I3w7H69nHfXdOG3UiadoBtjh3izSDM=

     

       
439
       
439
       
+
       
google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=

     

       
440
       
440
       
+
       
google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=

     

       
469
       
441
       
 
       
google.golang.org/protobuf v1.36.6 h1:z1NpPI8ku2WgiWnf+t9wTPsn6eP1L7ksHUlkfLvd9xY=

     

       
470
       
442
       
 
       
google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=

     

       
471
       
443
       
 
       
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

     

···

       
1
       
1
       
-
       
package inserter

     

       
1
       
1
       
+
       
package clickhouse_inserter

     

       
2
       
2
       
 
       


     

       
3
       
3
       
 
       
import (

     

       
4
       
4
       
 
       
	"context"

     

       
5
       
5
       
-
       
	"database/sql/driver"

     

       
6
       
5
       
 
       
	"log/slog"

     

       
7
       
6
       
 
       
	"slices"

     

       
8
       
7
       
 
       
	"sync"

     

       
9
       
8
       
 
       
	"time"

     

       
10
       
9
       
 
       


     

       
10
       
10
       
+
       
	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"

     

       
11
       
11
       
 
       
	"github.com/prometheus/client_golang/prometheus"

     

       
12
       
12
       
 
       
	"github.com/prometheus/client_golang/prometheus/promauto"

     

       
13
       
13
       
 
       
)

     

       
14
       
14
       
 
       


     

       
15
       
15
       
 
       
type Inserter struct {

     

       
16
       
16
       
-
       
	db             driver.Conn

     

       
16
       
16
       
+
       
	conn           driver.Conn

     

       
17
       
17
       
+
       
	query          string

     

       
17
       
18
       
 
       
	mu             sync.Mutex

     

       
18
       
19
       
 
       
	queuedEvents   []any

     

       
19
       
20
       
 
       
	batchSize      int

     
···

       
22
       
23
       
 
       
	histogram      *prometheus.HistogramVec

     

       
23
       
24
       
 
       
	logger         *slog.Logger

     

       
24
       
25
       
 
       
	prefix         string

     

       
25
       
25
       
-
       
}

     

       
26
       
26
       
-
       


     

       
27
       
27
       
-
       
type BaseArgs struct {

     

       
28
       
28
       
-
       
	CredentialsPath string

     

       
29
       
29
       
-
       
	ProjectID       string

     

       
30
       
30
       
-
       
	DatasetID       string

     

       
31
       
31
       
-
       
	TableID         string

     

       
32
       
26
       
 
       
}

     

       
33
       
27
       
 
       


     

       
34
       
28
       
 
       
type Args struct {

     

       
35
       
35
       
-
       
	BaseArgs

     

       
29
       
29
       
+
       
	Conn                    driver.Conn

     

       
30
       
30
       
+
       
	Query                   string

     

       
36
       
31
       
 
       
	BatchSize               int

     

       
37
       
32
       
 
       
	PrometheusCounterPrefix string

     

       
38
       
33
       
 
       
	Logger                  *slog.Logger

     
···

       
44
       
39
       
 
       
		args.Logger = slog.Default()

     

       
45
       
40
       
 
       
	}

     

       
46
       
41
       
 
       


     

       
47
       
47
       
-
       
	// dataset := bqc.Dataset(args.DatasetID)

     

       
48
       
48
       
-
       
	// table := dataset.Table(args.TableID)

     

       
49
       
49
       
-
       


     

       
50
       
50
       
-
       
	inserter := &Inserter{}

     

       
42
       
42
       
+
       
	inserter := &Inserter{

     

       
43
       
43
       
+
       
		conn:      args.Conn,

     

       
44
       
44
       
+
       
		query:     args.Query,

     

       
45
       
45
       
+
       
		mu:        sync.Mutex{},

     

       
46
       
46
       
+
       
		batchSize: args.BatchSize,

     

       
47
       
47
       
+
       
		histogram: args.Histogram,

     

       
48
       
48
       
+
       
		logger:    args.Logger,

     

       
49
       
49
       
+
       
		prefix:    args.PrometheusCounterPrefix,

     

       
50
       
50
       
+
       
	}

     

       
51
       
51
       
 
       


     

       
52
       
52
       
 
       
	if args.PrometheusCounterPrefix != "" {

     

       
53
       
53
       
 
       
		inserter.insertsCounter = promauto.NewCounterVec(prometheus.CounterOpts{

     
···

       
63
       
63
       
 
       
		})

     

       
64
       
64
       
 
       


     

       
65
       
65
       
 
       
	} else {

     

       
66
       
66
       
-
       
		args.Logger.Info("no prometheus prefix provided, no metrics will be registered for this counter", "dataset", args.DatasetID, "table", args.TableID)

     

       
66
       
66
       
+
       
		args.Logger.Info("no prometheus prefix provided, no metrics will be registered for this counter", "query", args.Query)

     

       
67
       
67
       
 
       
	}

     

       
68
       
68
       
 
       


     

       
69
       
69
       
 
       
	return inserter, nil

     
···

       
124
       
124
       
 
       
	}

     

       
125
       
125
       
 
       


     

       
126
       
126
       
 
       
	status := "ok"

     

       
127
       
127
       
+
       
	defer func() {

     

       
128
       
128
       
+
       
		i.insertsCounter.WithLabelValues(status).Add(float64(len(toInsert)))

     

       
129
       
129
       
+
       
	}()

     

       
127
       
130
       
 
       


     

       
128
       
128
       
-
       
	// TODO: do the insert

     

       
131
       
131
       
+
       
	batch, err := i.conn.PrepareBatch(ctx, i.query)

     

       
132
       
132
       
+
       
	if err != nil {

     

       
133
       
133
       
+
       
		i.logger.Error("error creating batch", "prefix", i.prefix, "error", err)

     

       
134
       
134
       
+
       
		status = "failed"

     

       
135
       
135
       
+
       
		return

     

       
136
       
136
       
+
       
	}

     

       
137
       
137
       
+
       


     

       
138
       
138
       
+
       
	for _, d := range toInsert {

     

       
139
       
139
       
+
       
		if err := batch.AppendStruct(&d); err != nil {

     

       
140
       
140
       
+
       
			i.logger.Error("error appending to batch", "prefix", i.prefix, "error", err)

     

       
141
       
141
       
+
       
		}

     

       
142
       
142
       
+
       
	}

     

       
129
       
143
       
 
       


     

       
130
       
130
       
-
       
	i.insertsCounter.WithLabelValues(status).Add(float64(len(toInsert)))

     

       
144
       
144
       
+
       
	if err := batch.Send(); err != nil {

     

       
145
       
145
       
+
       
		status = "failed"

     

       
146
       
146
       
+
       
		i.logger.Error("error sending batch", "prefix", i.prefix, "error", err)

     

       
147
       
147
       
+
       
	}

     

       
131
       
148
       
 
       
}

     

···

       
8
       
8
       
 
       
	"sync"

     

       
9
       
9
       
 
       
	"time"

     

       
10
       
10
       
 
       


     

       
11
       
11
       
-
       
	inserter "github.com/haileyok/photocopy/internal"

     

       
11
       
11
       
+
       
	"github.com/ClickHouse/clickhouse-go/v2"

     

       
12
       
12
       
+
       
	"github.com/haileyok/photocopy/clickhouse_inserter"

     

       
12
       
13
       
 
       
	"github.com/prometheus/client_golang/prometheus"

     

       
13
       
14
       
 
       
	"github.com/prometheus/client_golang/prometheus/promauto"

     

       
14
       
15
       
 
       
	"github.com/prometheus/client_golang/prometheus/promhttp"

     
···

       
29
       
30
       
 
       
}

     

       
30
       
31
       
 
       


     

       
31
       
32
       
 
       
type Inserters struct {

     

       
32
       
32
       
-
       
	followsInserter *inserter.Inserter

     

       
33
       
33
       
-
       
	plcInserter     *inserter.Inserter

     

       
33
       
33
       
+
       
	followsInserter *clickhouse_inserter.Inserter

     

       
34
       
34
       
+
       
	plcInserter     *clickhouse_inserter.Inserter

     

       
34
       
35
       
 
       
}

     

       
35
       
36
       
 
       


     

       
36
       
37
       
 
       
type Args struct {

     
···

       
39
       
40
       
 
       
	MetricsAddr          string

     

       
40
       
41
       
 
       
	CursorFile           string

     

       
41
       
42
       
 
       
	PLCScraperCursorFile string

     

       
43
       
43
       
+
       
	ClickhouseAddr       string

     

       
44
       
44
       
+
       
	ClickhouseDatabase   string

     

       
42
       
45
       
 
       
	ClickhouseUser       string

     

       
43
       
46
       
 
       
	ClickhousePass       string

     

       
44
       
47
       
 
       
}

     
···

       
52
       
55
       
 
       
		cursorFile:  args.CursorFile,

     

       
53
       
56
       
 
       
	}

     

       
54
       
57
       
 
       


     

       
58
       
58
       
+
       
	conn, err := clickhouse.Open(&clickhouse.Options{

     

       
59
       
59
       
+
       
		Addr: []string{args.ClickhouseAddr},

     

       
60
       
60
       
+
       
		Auth: clickhouse.Auth{

     

       
61
       
61
       
+
       
			Database: args.ClickhouseDatabase,

     

       
62
       
62
       
+
       
			Username: args.ClickhouseUser,

     

       
63
       
63
       
+
       
			Password: args.ClickhousePass,

     

       
64
       
64
       
+
       
		},

     

       
65
       
65
       
+
       
	})

     

       
66
       
66
       
+
       
	if err != nil {

     

       
67
       
67
       
+
       
		return nil, err

     

       
68
       
68
       
+
       
	}

     

       
69
       
69
       
+
       


     

       
55
       
70
       
 
       
	insertionsHist := promauto.NewHistogramVec(prometheus.HistogramOpts{

     

       
56
       
71
       
 
       
		Name:    "photocopy_inserts_time",

     

       
57
       
72
       
 
       
		Help:    "histogram of photocopy inserts",

     

       
58
       
73
       
 
       
		Buckets: prometheus.ExponentialBucketsRange(0.0001, 30, 20),

     

       
59
       
74
       
 
       
	}, []string{"type"})

     

       
60
       
75
       
 
       


     

       
61
       
61
       
-
       
	fi, err := inserter.New(ctx, &inserter.Args{

     

       
76
       
76
       
+
       
	fi, err := clickhouse_inserter.New(ctx, &clickhouse_inserter.Args{

     

       
62
       
77
       
 
       
		PrometheusCounterPrefix: "photocopy_follows",

     

       
63
       
78
       
 
       
		Histogram:               insertionsHist,

     

       
64
       
79
       
 
       
		BatchSize:               100,

     

       
65
       
80
       
 
       
		Logger:                  p.logger,

     

       
81
       
81
       
+
       
		Conn:                    conn,

     

       
82
       
82
       
+
       
		Query:                   "",

     

       
66
       
83
       
 
       
	})

     

       
67
       
84
       
 
       
	if err != nil {

     

       
68
       
85
       
 
       
		return nil, err

     
···

       
74
       
91
       
 
       


     

       
75
       
92
       
 
       
	p.inserters = is

     

       
76
       
93
       
 
       


     

       
77
       
77
       
-
       
	plci, err := inserter.New(ctx, &inserter.Args{

     

       
94
       
94
       
+
       
	plci, err := clickhouse_inserter.New(ctx, &clickhouse_inserter.Args{

     

       
78
       
95
       
 
       
		PrometheusCounterPrefix: "photocopy_plc_entries",

     

       
79
       
96
       
 
       
		Histogram:               insertionsHist,

     

       
80
       
97
       
 
       
		BatchSize:               100,

     

       
81
       
98
       
 
       
		Logger:                  args.Logger,

     

       
99
       
99
       
+
       
		Conn:                    conn,

     

       
100
       
100
       
+
       
		Query: `INSERT INTO your_table_name (

     

       
101
       
101
       
+
       
			did, cid, nullified, created_at, plc_op_sig, plc_op_prev, plc_op_type,

     

       
102
       
102
       
+
       
			plc_op_services, plc_op_also_known_as, plc_op_rotation_keys,

     

       
103
       
103
       
+
       
			plc_op_verification_methods, plc_tomb_sig, plc_tomb_prev, plc_tomb_type,

     

       
104
       
104
       
+
       
			legacy_op_sig, legacy_op_prev, legacy_op_type, legacy_op_handle,

     

       
105
       
105
       
+
       
			legacy_op_service, legacy_op_signing_key, legacy_op_recovery_key

     

       
106
       
106
       
+
       
		)`,

     

       
82
       
107
       
 
       
	})

     

       
83
       
108
       
 
       
	if err != nil {

     

       
84
       
109
       
 
       
		return nil, err

     

···

       
2
       
2
       
 
       


     

       
3
       
3
       
 
       
import (

     

       
4
       
4
       
 
       
	"encoding/json"

     

       
5
       
5
       
-
       
	"errors"

     

       
6
       
5
       
 
       
	"fmt"

     

       
7
       
6
       
 
       
	"time"

     

       
8
       
8
       
-
       


     

       
9
       
9
       
-
       
	"cloud.google.com/go/bigquery"

     

       
10
       
7
       
 
       
)

     

       
11
       
8
       
 
       


     

       
12
       
9
       
 
       
type PLCEntry struct {

     

       
13
       
13
       
-
       
	Did       string           `json:"did" bigquery:"did"`

     

       
14
       
14
       
-
       
	Operation PLCOperationType `json:"operation" bigquery:"operation"`

     

       
15
       
15
       
-
       
	Cid       string           `json:"cid" bigquery:"cid"`

     

       
16
       
16
       
-
       
	Nullified bool             `json:"nullified" bigquery:"nullified"`

     

       
17
       
17
       
-
       
	CreatedAt time.Time        `json:"createdAt" bigquery:"created_at"`

     

       
10
       
10
       
+
       
	Did       string           `json:"did"`

     

       
11
       
11
       
+
       
	Operation PLCOperationType `json:"operation"`

     

       
12
       
12
       
+
       
	Cid       string           `json:"cid"`

     

       
13
       
13
       
+
       
	Nullified bool             `json:"nullified"`

     

       
14
       
14
       
+
       
	CreatedAt time.Time        `json:"createdAt"`

     

       
18
       
15
       
 
       
}

     

       
19
       
16
       
 
       


     

       
20
       
17
       
 
       
type PLCOperation struct {

     

       
21
       
21
       
-
       
	Sig                     string                `json:"sig" bigquery:"sig"`

     

       
22
       
22
       
-
       
	Prev                    bigquery.NullString   `json:"prev" bigquery:"prev"`

     

       
23
       
23
       
-
       
	Type                    string                `json:"type" bigquery:"type"`

     

       
24
       
24
       
-
       
	Services                map[string]PLCService `json:"services" bigquery:"-"`

     

       
25
       
25
       
-
       
	ServicesJSON            string                `json:"-" bigquery:"services"`

     

       
26
       
26
       
-
       
	AlsoKnownAs             []string              `json:"alsoKnownAs" bigquery:"also_known_as"`

     

       
27
       
27
       
-
       
	RotationKeys            []string              `json:"rotationKeys" bigquery:"rotation_keys"`

     

       
28
       
28
       
-
       
	VerificationMethods     map[string]string     `json:"verificationMethods" bigquery:"-"`

     

       
29
       
29
       
-
       
	VerificationMethodsJSON string                `json:"-" bigquery:"verification_methods"`

     

       
18
       
18
       
+
       
	Sig                 string                `json:"sig" `

     

       
19
       
19
       
+
       
	Prev                *string               `json:"prev"`

     

       
20
       
20
       
+
       
	Type                string                `json:"type"`

     

       
21
       
21
       
+
       
	Services            map[string]PLCService `json:"services"`

     

       
22
       
22
       
+
       
	AlsoKnownAs         []string              `json:"alsoKnownAs"`

     

       
23
       
23
       
+
       
	RotationKeys        []string              `json:"rotationKeys"`

     

       
24
       
24
       
+
       
	VerificationMethods map[string]string     `json:"verificationMethods"`

     

       
30
       
25
       
 
       
}

     

       
31
       
26
       
 
       


     

       
32
       
27
       
 
       
type PLCTombstone struct {

     
···

       
51
       
46
       
 
       
}

     

       
52
       
47
       
 
       


     

       
53
       
48
       
 
       
type PLCOperationType struct {

     

       
54
       
54
       
-
       
	OperationType      string              `json:"-" bigquery:"operation_type"`

     

       
55
       
55
       
-
       
	PLCOperation       *PLCOperation       `json:"-" bigquery:"plc_operation"`

     

       
56
       
56
       
-
       
	PLCTombstone       *PLCTombstone       `json:"-" bigquery:"plc_tombstone"`

     

       
57
       
57
       
-
       
	LegacyPLCOperation *LegacyPLCOperation `json:"-" bigquery:"legacy_plc_operation"`

     

       
49
       
49
       
+
       
	OperationType      string

     

       
50
       
50
       
+
       
	PLCOperation       *PLCOperation

     

       
51
       
51
       
+
       
	PLCTombstone       *PLCTombstone

     

       
52
       
52
       
+
       
	LegacyPLCOperation *LegacyPLCOperation

     

       
53
       
53
       
+
       
}

     

       
54
       
54
       
+
       


     

       
55
       
55
       
+
       
type ClickhousePLCEntry struct {

     

       
56
       
56
       
+
       
	Did                      string    `ch:"did"`

     

       
57
       
57
       
+
       
	Cid                      string    `ch:"cid"`

     

       
58
       
58
       
+
       
	Nullified                bool      `ch:"nullified"`

     

       
59
       
59
       
+
       
	CreatedAt                time.Time `ch:"created_at"`

     

       
60
       
60
       
+
       
	PlcOpSig                 string    `ch:"plc_op_sig"`

     

       
61
       
61
       
+
       
	PlcOpPrev                *string   `ch:"plc_op_prev"`

     

       
62
       
62
       
+
       
	PlcOpType                string    `ch:"plc_op_type"`

     

       
63
       
63
       
+
       
	PlcOpServices            string    `ch:"plc_op_services"`

     

       
64
       
64
       
+
       
	PlcOpAlsoKnownAs         []string  `ch:"plc_op_also_known_as"`

     

       
65
       
65
       
+
       
	PlcOpRotationKeys        []string  `ch:"plc_op_rotation_keys"`

     

       
66
       
66
       
+
       
	PlcOpVerificationMethods string    `ch:"plc_op_verification_methods"`

     

       
67
       
67
       
+
       
	PlcTombSig               string    `ch:"plc_tomb_sig"`

     

       
68
       
68
       
+
       
	PlcTombPrev              string    `ch:"plc_tomb_prev"`

     

       
69
       
69
       
+
       
	PlcTombType              string    `ch:"plc_tomb_type"`

     

       
70
       
70
       
+
       
	LegacyOpSig              string    `ch:"legacy_op_sig"`

     

       
71
       
71
       
+
       
	LegacyOpPrev             string    `ch:"legacy_op_prev"`

     

       
72
       
72
       
+
       
	LegacyOpType             string    `ch:"legacy_op_type"`

     

       
73
       
73
       
+
       
	LegacyOpHandle           string    `ch:"legacy_op_handle"`

     

       
74
       
74
       
+
       
	LegacyOpService          string    `ch:"legacy_op_service"`

     

       
75
       
75
       
+
       
	LegacyOpSigningKey       string    `ch:"legacy_op_signing_key"`

     

       
76
       
76
       
+
       
	LegacyOpRecoveryKey      string    `ch:"legacy_op_recovery_key"`

     

       
58
       
77
       
 
       
}

     

       
59
       
78
       
 
       


     

       
60
       
79
       
 
       
func (o *PLCOperationType) UnmarshalJSON(data []byte) error {

     
···

       
105
       
124
       
 
       
	return nil

     

       
106
       
125
       
 
       
}

     

       
107
       
126
       
 
       


     

       
108
       
108
       
-
       
func (o *PLCOperationType) MarshalJSON() ([]byte, error) {

     

       
109
       
109
       
-
       
	if o.PLCOperation != nil {

     

       
110
       
110
       
-
       
		return json.Marshal(o.PLCOperation)

     

       
111
       
111
       
-
       
	}

     

       
112
       
112
       
-
       
	if o.PLCTombstone != nil {

     

       
113
       
113
       
-
       
		return json.Marshal(o.PLCTombstone)

     

       
114
       
114
       
-
       
	}

     

       
115
       
115
       
-
       
	if o.LegacyPLCOperation != nil {

     

       
116
       
116
       
-
       
		return json.Marshal(o.LegacyPLCOperation)

     

       
127
       
127
       
+
       
func (e *PLCEntry) prepareForClickhouse() (*ClickhousePLCEntry, error) {

     

       
128
       
128
       
+
       
	che := &ClickhousePLCEntry{

     

       
129
       
129
       
+
       
		Did:       e.Did,

     

       
130
       
130
       
+
       
		Cid:       e.Cid,

     

       
131
       
131
       
+
       
		Nullified: e.Nullified,

     

       
132
       
132
       
+
       
		CreatedAt: e.CreatedAt,

     

       
117
       
133
       
 
       
	}

     

       
118
       
118
       
-
       
	return nil, errors.New("no valid operation type found")

     

       
119
       
119
       
-
       
}

     

       
120
       
120
       
-
       


     

       
121
       
121
       
-
       
func (o *PLCOperationType) Value() (any, error) {

     

       
122
       
122
       
-
       
	return json.Marshal(o)

     

       
123
       
123
       
-
       
}

     

       
124
       
124
       
-
       


     

       
125
       
125
       
-
       
func (o *PLCOperationType) Scan(value any) error {

     

       
126
       
126
       
-
       
	bytes, ok := value.([]byte)

     

       
127
       
127
       
-
       
	if !ok {

     

       
128
       
128
       
-
       
		return errors.New("could not scan PLCOperationType")

     

       
129
       
129
       
-
       
	}

     

       
130
       
130
       
-
       
	return json.Unmarshal(bytes, o)

     

       
131
       
131
       
-
       
}

     

       
132
       
132
       
-
       


     

       
133
       
133
       
-
       
func (e *PLCEntry) prepareForBigQuery() (map[string]bigquery.Value, string, error) {

     

       
134
       
134
       
 
       
	if e.Operation.PLCOperation != nil {

     

       
135
       
135
       
+
       
		pop := e.Operation.PLCOperation

     

       
136
       
136
       
+
       
		che.PlcOpSig = pop.Sig

     

       
137
       
137
       
+
       
		che.PlcOpPrev = pop.Prev

     

       
138
       
138
       
+
       
		che.PlcOpType = pop.Type

     

       
139
       
139
       
+
       
		che.PlcOpAlsoKnownAs = pop.AlsoKnownAs

     

       
140
       
140
       
+
       
		che.PlcOpRotationKeys = pop.RotationKeys

     

       
135
       
141
       
 
       
		if e.Operation.PLCOperation.Services != nil {

     

       
136
       
142
       
 
       
			b, err := json.Marshal(e.Operation.PLCOperation.Services)

     

       
137
       
143
       
 
       
			if err != nil {

     

       
138
       
138
       
-
       
				return nil, "", fmt.Errorf("error marshaling services: %w", err)

     

       
144
       
144
       
+
       
				return nil, fmt.Errorf("error marshaling services: %w", err)

     

       
139
       
145
       
 
       
			}

     

       
140
       
140
       
-
       
			e.Operation.PLCOperation.ServicesJSON = string(b)

     

       
146
       
146
       
+
       
			che.PlcOpServices = string(b)

     

       
141
       
147
       
 
       
		}

     

       
142
       
148
       
 
       
		if e.Operation.PLCOperation.VerificationMethods != nil {

     

       
143
       
149
       
 
       
			b, err := json.Marshal(e.Operation.PLCOperation.VerificationMethods)

     

       
144
       
150
       
 
       
			if err != nil {

     

       
145
       
145
       
-
       
				return nil, "", fmt.Errorf("error marshaling verification methods: %w", err)

     

       
151
       
151
       
+
       
				return nil, fmt.Errorf("error marshaling verification methods: %w", err)

     

       
146
       
152
       
 
       
			}

     

       
147
       
147
       
-
       
			e.Operation.PLCOperation.VerificationMethodsJSON = string(b)

     

       
153
       
153
       
+
       
			che.PlcOpVerificationMethods = string(b)

     

       
148
       
154
       
 
       
		}

     

       
155
       
155
       
+
       
		return che, nil

     

       
156
       
156
       
+
       
	} else if e.Operation.PLCTombstone != nil {

     

       
157
       
157
       
+
       
		che.PlcTombSig = e.Operation.PLCTombstone.Sig

     

       
158
       
158
       
+
       
		che.PlcTombPrev = e.Operation.PLCTombstone.Prev

     

       
159
       
159
       
+
       
		che.PlcTombType = e.Operation.PLCTombstone.Type

     

       
160
       
160
       
+
       
		return che, nil

     

       
161
       
161
       
+
       
	} else if e.Operation.LegacyPLCOperation != nil {

     

       
162
       
162
       
+
       
		lop := e.Operation.LegacyPLCOperation

     

       
163
       
163
       
+
       
		che.LegacyOpSig = lop.Sig

     

       
164
       
164
       
+
       
		che.LegacyOpPrev = lop.Prev

     

       
165
       
165
       
+
       
		che.LegacyOpType = lop.Type

     

       
166
       
166
       
+
       
		che.LegacyOpService = lop.Service

     

       
167
       
167
       
+
       
		che.LegacyOpHandle = lop.Handle

     

       
168
       
168
       
+
       
		che.LegacyOpSigningKey = lop.SigningKey

     

       
169
       
169
       
+
       
		che.LegacyOpRecoveryKey = lop.RecoveryKey

     

       
149
       
170
       
 
       
	}

     

       
150
       
150
       
-
       
	return nil, "", nil

     

       
171
       
171
       
+
       


     

       
172
       
172
       
+
       
	return nil, fmt.Errorf("no valid plc operation type")

     

       
151
       
173
       
 
       
}

     

···

       
11
       
11
       
 
       
	"strings"

     

       
12
       
12
       
 
       
	"time"

     

       
13
       
13
       
 
       


     

       
14
       
14
       
-
       
	inserter "github.com/haileyok/photocopy/internal"

     

       
14
       
14
       
+
       
	"github.com/haileyok/photocopy/clickhouse_inserter"

     

       
15
       
15
       
 
       
)

     

       
16
       
16
       
 
       


     

       
17
       
17
       
 
       
type PLCScraper struct {

     
···

       
19
       
19
       
 
       
	logger     *slog.Logger

     

       
20
       
20
       
 
       
	cursor     string

     

       
21
       
21
       
 
       
	cursorFile string

     

       
22
       
22
       
-
       
	inserter   *inserter.Inserter

     

       
22
       
22
       
+
       
	inserter   *clickhouse_inserter.Inserter

     

       
23
       
23
       
 
       
}

     

       
24
       
24
       
 
       


     

       
25
       
25
       
 
       
type PLCScraperArgs struct {

     

       
26
       
26
       
 
       
	Logger     *slog.Logger

     

       
27
       
27
       
-
       
	Inserter   *inserter.Inserter

     

       
27
       
27
       
+
       
	Inserter   *clickhouse_inserter.Inserter

     

       
28
       
28
       
 
       
	CursorFile string

     

       
29
       
29
       
 
       
}

     

       
30
       
30
       
 
       


     
···

       
129
       
129
       
 
       
				s.saveCursor(s.cursor)

     

       
130
       
130
       
 
       
			}

     

       
131
       
131
       
 
       


     

       
132
       
132
       
-
       
			entry.prepareForBigQuery()

     

       
132
       
132
       
+
       
			chEntry, err := entry.prepareForClickhouse()

     

       
133
       
133
       
+
       
			if err != nil {

     

       
134
       
134
       
+
       
				s.logger.Error("error getting clickhouse entry from plc entry", "error", err)

     

       
135
       
135
       
+
       
				continue

     

       
136
       
136
       
+
       
			}

     

       
133
       
137
       
 
       


     

       
134
       
134
       
-
       
			s.inserter.Insert(ctx, entry)

     

       
138
       
138
       
+
       
			s.inserter.Insert(ctx, chEntry)

     

       
135
       
139
       
 
       
		}

     

       
136
       
140
       
 
       
	}

     

       
137
       
141