Skip to content

Commit e9f7efc

Browse files
jakeloojakeloo
authored
Optimize embedded db memory and disk (#281)
* Add Pebble. Tune Badger * Cleanup unused configs * Remove unused code. Fix context cancellation cleanups * committer until block -> to block * ensure validated blocks on commit * remove unused var * Fix lastPolledBlockNumber * Fix flags * Fix poller waiting for blocks * Add old format tables schema * Pebble experimental only * Snappy -> ZSTD for badger
1 parent fcca23a commit e9f7efc

20 files changed

+1704
-528
lines changed

‎cmd/root.go‎

Lines changed: 8 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -49,13 +49,8 @@ func init() {
4949
rootCmd.PersistentFlags().Int("rpc-traces-batchDelay", 0, "Milliseconds to wait between batches of traces when fetching from the RPC")
5050
rootCmd.PersistentFlags().String("log-level", "", "Log level to use for the application")
5151
rootCmd.PersistentFlags().Bool("log-prettify", false, "Whether to prettify the log output")
52-
rootCmd.PersistentFlags().Bool("poller-enabled", true, "Toggle poller")
53-
rootCmd.PersistentFlags().Bool("poller-interval", true, "Poller interval")
54-
rootCmd.PersistentFlags().Int("poller-blocks-per-poll", 10, "How many blocks to poll each interval")
55-
rootCmd.PersistentFlags().Int("poller-from-block", 0, "From which block to start polling")
56-
rootCmd.PersistentFlags().Int("poller-until-block", 0, "Until which block to poll")
5752
rootCmd.PersistentFlags().Int("poller-parallel-pollers", 5, "Maximum number of parallel pollers")
58-
rootCmd.PersistentFlags().String("poller-s3-bucket", "", "S3 bucket for poller archive source")
53+
rootCmd.PersistentFlags().String("poller-s3-bucket", "", "S3 bucket for oller archive source")
5954
rootCmd.PersistentFlags().String("poller-s3-region", "", "S3 region for poller archive source")
6055
rootCmd.PersistentFlags().String("poller-s3-prefix", "", "S3 prefix for poller archive source")
6156
rootCmd.PersistentFlags().String("poller-s3-accessKeyId", "", "S3 access key ID for poller archive source")
@@ -72,6 +67,7 @@ func init() {
7267
rootCmd.PersistentFlags().Int("committer-blocks-per-commit", 10, "How many blocks to commit each interval")
7368
rootCmd.PersistentFlags().Int("committer-interval", 1000, "How often to commit blocks in milliseconds")
7469
rootCmd.PersistentFlags().Int("committer-from-block", 0, "From which block to start committing")
70+
rootCmd.PersistentFlags().Int("committer-to-block", 0, "To which block to commit")
7571
rootCmd.PersistentFlags().Bool("reorgHandler-enabled", true, "Toggle reorg handler")
7672
rootCmd.PersistentFlags().Int("reorgHandler-interval", 1000, "How often to run reorg handler in milliseconds")
7773
rootCmd.PersistentFlags().Int("reorgHandler-blocks-per-scan", 100, "How many blocks to scan for reorgs")
@@ -152,6 +148,8 @@ func init() {
152148
rootCmd.PersistentFlags().String("storage-orchestrator-type", "auto", "Storage type for orchestrator (auto, clickhouse, postgres, badger)")
153149
rootCmd.PersistentFlags().String("storage-staging-badger-path", "", "BadgerDB path for staging storage")
154150
rootCmd.PersistentFlags().String("storage-orchestrator-badger-path", "", "BadgerDB path for orchestrator storage")
151+
rootCmd.PersistentFlags().String("storage-orchestrator-pebble-path", "", "PebbleDB path for orchestrator storage")
152+
rootCmd.PersistentFlags().String("storage-staging-pebble-path", "", "PebbleDB path for staging storage")
155153
rootCmd.PersistentFlags().String("storage-main-s3-bucket", "", "S3 bucket for main storage")
156154
rootCmd.PersistentFlags().String("storage-main-s3-region", "", "S3 region for main storage")
157155
rootCmd.PersistentFlags().String("storage-main-s3-prefix", "", "S3 key prefix for main storage")
@@ -196,7 +194,7 @@ func init() {
196194
rootCmd.PersistentFlags().Int("workMode-checkIntervalMinutes", 10, "How often to check work mode in minutes")
197195
rootCmd.PersistentFlags().Int64("workMode-liveModeThreshold", 500, "How many blocks the indexer can be behind before switching to live mode")
198196
rootCmd.PersistentFlags().String("validation-mode", "strict", "Validation mode. Strict will validate logsBloom and transactionsRoot. Minimal will validate transaction count and logs existence.")
199-
rootCmd.PersistentFlags().String("migrator-destination-type", "auto", "Storage type for migrator destination (auto, clickhouse, postgres, kafka, badger, s3)")
197+
rootCmd.PersistentFlags().String("migrator-destination-type", "auto", "Storage type for migrator destination (auto, clickhouse, postgres, kafka, badger, pebble, s3)")
200198
rootCmd.PersistentFlags().String("migrator-destination-clickhouse-host", "", "Clickhouse host for migrator destination")
201199
rootCmd.PersistentFlags().Int("migrator-destination-clickhouse-port", 0, "Clickhouse port for migrator destination")
202200
rootCmd.PersistentFlags().String("migrator-destination-clickhouse-username", "", "Clickhouse username for migrator destination")
@@ -221,7 +219,6 @@ func init() {
221219
rootCmd.PersistentFlags().String("migrator-destination-kafka-username", "", "Kafka username for migrator destination")
222220
rootCmd.PersistentFlags().String("migrator-destination-kafka-password", "", "Kafka password for migrator destination")
223221
rootCmd.PersistentFlags().Bool("migrator-destination-kafka-enableTLS", true, "Enable TLS for Kafka connection in migrator destination")
224-
rootCmd.PersistentFlags().String("migrator-destination-badger-path", "", "BadgerDB path for migrator destination")
225222
rootCmd.PersistentFlags().String("migrator-destination-s3-bucket", "", "S3 bucket for migrator destination")
226223
rootCmd.PersistentFlags().String("migrator-destination-s3-region", "", "S3 region for migrator destination")
227224
rootCmd.PersistentFlags().String("migrator-destination-s3-prefix", "", "S3 key prefix for migrator destination")
@@ -251,10 +248,6 @@ func init() {
251248
viper.BindPFlag("log.level", rootCmd.PersistentFlags().Lookup("log-level"))
252249
viper.BindPFlag("log.prettify", rootCmd.PersistentFlags().Lookup("log-prettify"))
253250
viper.BindPFlag("poller.enabled", rootCmd.PersistentFlags().Lookup("poller-enabled"))
254-
viper.BindPFlag("poller.interval", rootCmd.PersistentFlags().Lookup("poller-interval"))
255-
viper.BindPFlag("poller.blocksPerPoll", rootCmd.PersistentFlags().Lookup("poller-blocks-per-poll"))
256-
viper.BindPFlag("poller.fromBlock", rootCmd.PersistentFlags().Lookup("poller-from-block"))
257-
viper.BindPFlag("poller.untilBlock", rootCmd.PersistentFlags().Lookup("poller-until-block"))
258251
viper.BindPFlag("poller.parallelPollers", rootCmd.PersistentFlags().Lookup("poller-parallel-pollers"))
259252
viper.BindPFlag("poller.s3.endpoint", rootCmd.PersistentFlags().Lookup("poller-s3-endpoint"))
260253
viper.BindPFlag("poller.s3.accessKeyId", rootCmd.PersistentFlags().Lookup("poller-s3-accessKeyId"))
@@ -272,6 +265,7 @@ func init() {
272265
viper.BindPFlag("committer.blocksPerCommit", rootCmd.PersistentFlags().Lookup("committer-blocks-per-commit"))
273266
viper.BindPFlag("committer.interval", rootCmd.PersistentFlags().Lookup("committer-interval"))
274267
viper.BindPFlag("committer.fromBlock", rootCmd.PersistentFlags().Lookup("committer-from-block"))
268+
viper.BindPFlag("committer.toBlock", rootCmd.PersistentFlags().Lookup("committer-to-block"))
275269
viper.BindPFlag("reorgHandler.enabled", rootCmd.PersistentFlags().Lookup("reorgHandler-enabled"))
276270
viper.BindPFlag("reorgHandler.interval", rootCmd.PersistentFlags().Lookup("reorgHandler-interval"))
277271
viper.BindPFlag("reorgHandler.blocksPerScan", rootCmd.PersistentFlags().Lookup("reorgHandler-blocks-per-scan"))
@@ -334,6 +328,7 @@ func init() {
334328
viper.BindPFlag("storage.orchestrator.redis.db", rootCmd.PersistentFlags().Lookup("storage-orchestrator-redis-db"))
335329
viper.BindPFlag("storage.orchestrator.redis.enableTLS", rootCmd.PersistentFlags().Lookup("storage-orchestrator-redis-enableTLS"))
336330
viper.BindPFlag("storage.orchestrator.badger.path", rootCmd.PersistentFlags().Lookup("storage-orchestrator-badger-path"))
331+
viper.BindPFlag("storage.orchestrator.pebble.path", rootCmd.PersistentFlags().Lookup("storage-orchestrator-pebble-path"))
337332
viper.BindPFlag("storage.orchestrator.type", rootCmd.PersistentFlags().Lookup("storage-orchestrator-type"))
338333
viper.BindPFlag("storage.staging.postgres.host", rootCmd.PersistentFlags().Lookup("storage-staging-postgres-host"))
339334
viper.BindPFlag("storage.staging.postgres.port", rootCmd.PersistentFlags().Lookup("storage-staging-postgres-port"))
@@ -346,6 +341,7 @@ func init() {
346341
viper.BindPFlag("storage.staging.postgres.maxConnLifetime", rootCmd.PersistentFlags().Lookup("storage-staging-postgres-maxConnLifetime"))
347342
viper.BindPFlag("storage.staging.postgres.connectTimeout", rootCmd.PersistentFlags().Lookup("storage-staging-postgres-connectTimeout"))
348343
viper.BindPFlag("storage.staging.badger.path", rootCmd.PersistentFlags().Lookup("storage-staging-badger-path"))
344+
viper.BindPFlag("storage.staging.pebble.path", rootCmd.PersistentFlags().Lookup("storage-staging-pebble-path"))
349345
viper.BindPFlag("storage.staging.type", rootCmd.PersistentFlags().Lookup("storage-staging-type"))
350346
viper.BindPFlag("storage.main.kafka.brokers", rootCmd.PersistentFlags().Lookup("storage-main-kafka-brokers"))
351347
viper.BindPFlag("storage.main.kafka.username", rootCmd.PersistentFlags().Lookup("storage-main-kafka-username"))
@@ -422,7 +418,6 @@ func init() {
422418
viper.BindPFlag("migrator.destination.kafka.username", rootCmd.PersistentFlags().Lookup("migrator-destination-kafka-username"))
423419
viper.BindPFlag("migrator.destination.kafka.password", rootCmd.PersistentFlags().Lookup("migrator-destination-kafka-password"))
424420
viper.BindPFlag("migrator.destination.kafka.enableTLS", rootCmd.PersistentFlags().Lookup("migrator-destination-kafka-enableTLS"))
425-
viper.BindPFlag("migrator.destination.badger.path", rootCmd.PersistentFlags().Lookup("migrator-destination-badger-path"))
426421
viper.BindPFlag("migrator.destination.s3.bucket", rootCmd.PersistentFlags().Lookup("migrator-destination-s3-bucket"))
427422
viper.BindPFlag("migrator.destination.s3.region", rootCmd.PersistentFlags().Lookup("migrator-destination-s3-region"))
428423
viper.BindPFlag("migrator.destination.s3.prefix", rootCmd.PersistentFlags().Lookup("migrator-destination-s3-prefix"))

‎configs/config.go‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,6 @@ type LogConfig struct {
1818

1919
type PollerConfig struct {
2020
Enabled bool `mapstructure:"enabled"`
21-
Interval int `mapstructure:"interval"`
22-
BlocksPerPoll int `mapstructure:"blocksPerPoll"`
23-
FromBlock int `mapstructure:"fromBlock"`
24-
ForceFromBlock bool `mapstructure:"forceFromBlock"`
25-
UntilBlock int `mapstructure:"untilBlock"`
2621
ParallelPollers int `mapstructure:"parallelPollers"`
2722
S3 *S3SourceConfig `mapstructure:"s3"`
2823
}
@@ -32,7 +27,7 @@ type CommitterConfig struct {
3227
Interval int `mapstructure:"interval"`
3328
BlocksPerCommit int `mapstructure:"blocksPerCommit"`
3429
FromBlock int `mapstructure:"fromBlock"`
35-
UntilBlock int `mapstructure:"untilBlock"`
30+
ToBlock int `mapstructure:"toBlock"`
3631
}
3732

3833
type ReorgHandlerConfig struct {
@@ -61,28 +56,33 @@ type StorageOrchestratorConfig struct {
6156
Postgres *PostgresConfig `mapstructure:"postgres"`
6257
Redis *RedisConfig `mapstructure:"redis"`
6358
Badger *BadgerConfig `mapstructure:"badger"`
59+
Pebble *PebbleConfig `mapstructure:"pebble"`
6460
}
6561

6662
type StorageStagingConfig struct {
6763
Type string `mapstructure:"type"`
6864
Clickhouse *ClickhouseConfig `mapstructure:"clickhouse"`
6965
Postgres *PostgresConfig `mapstructure:"postgres"`
7066
Badger *BadgerConfig `mapstructure:"badger"`
67+
Pebble *PebbleConfig `mapstructure:"pebble"`
7168
}
7269

7370
type StorageMainConfig struct {
7471
Type string `mapstructure:"type"`
7572
Clickhouse *ClickhouseConfig `mapstructure:"clickhouse"`
7673
Postgres *PostgresConfig `mapstructure:"postgres"`
7774
Kafka *KafkaConfig `mapstructure:"kafka"`
78-
Badger *BadgerConfig `mapstructure:"badger"`
7975
S3 *S3StorageConfig `mapstructure:"s3"`
8076
}
8177

8278
type BadgerConfig struct {
8379
Path string `mapstructure:"path"`
8480
}
8581

82+
type PebbleConfig struct {
83+
Path string `mapstructure:"path"`
84+
}
85+
8686
type S3Config struct {
8787
Bucket string `mapstructure:"bucket"`
8888
Region string `mapstructure:"region"`
@@ -97,8 +97,8 @@ type S3StorageConfig struct {
9797
Format string `mapstructure:"format"`
9898
Parquet *ParquetConfig `mapstructure:"parquet"`
9999
// Buffering configuration
100-
BufferSize int64 `mapstructure:"bufferSizeMB"` // Target buffer size in MB before flush (default 512 MB)
101-
BufferTimeout int `mapstructure:"bufferTimeoutSeconds"` // Max time in seconds before flush (default 300 = 5 min)
100+
BufferSize int64 `mapstructure:"bufferSizeMB"` // Target buffer size in MB before flush
101+
BufferTimeout int `mapstructure:"bufferTimeoutSeconds"` // Max time in seconds before flush
102102
MaxBlocksPerFile int `mapstructure:"maxBlocksPerFile"` // Max blocks per parquet file (0 = no limit, only size/timeout triggers)
103103
}
104104

‎go.mod‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ require (
77
github.com/aws/aws-sdk-go-v2 v1.38.0
88
github.com/aws/aws-sdk-go-v2/config v1.31.0
99
github.com/aws/aws-sdk-go-v2/service/s3 v1.87.0
10+
github.com/cockroachdb/pebble v1.1.2
1011
github.com/dgraph-io/badger/v4 v4.8.0
1112
github.com/ethereum/go-ethereum v1.15.11
1213
github.com/gin-gonic/gin v1.10.0
@@ -28,6 +29,7 @@ require (
2829

2930
require (
3031
github.com/ClickHouse/ch-go v0.66.0 // indirect
32+
github.com/DataDog/zstd v1.4.5 // indirect
3133
github.com/KyleBanks/depth v1.2.1 // indirect
3234
github.com/Microsoft/go-winio v0.6.2 // indirect
3335
github.com/andybalholm/brotli v1.1.1 // indirect
@@ -53,6 +55,11 @@ require (
5355
github.com/cespare/xxhash/v2 v2.3.0 // indirect
5456
github.com/cloudwego/base64x v0.1.4 // indirect
5557
github.com/cloudwego/iasm v0.2.0 // indirect
58+
github.com/cockroachdb/errors v1.11.3 // indirect
59+
github.com/cockroachdb/fifo v0.0.0-20240606204812-0bbfbd93a7ce // indirect
60+
github.com/cockroachdb/logtags v0.0.0-20230118201751-21c54148d20b // indirect
61+
github.com/cockroachdb/redact v1.1.5 // indirect
62+
github.com/cockroachdb/tokenbucket v0.0.0-20230807174530-cc333fc44b06 // indirect
5663
github.com/consensys/bavard v0.1.27 // indirect
5764
github.com/consensys/gnark-crypto v0.16.0 // indirect
5865
github.com/crate-crypto/go-eth-kzg v1.3.0 // indirect
@@ -67,6 +74,7 @@ require (
6774
github.com/ethereum/go-verkle v0.2.2 // indirect
6875
github.com/fsnotify/fsnotify v1.7.0 // indirect
6976
github.com/gabriel-vasile/mimetype v1.4.7 // indirect
77+
github.com/getsentry/sentry-go v0.27.0 // indirect
7078
github.com/gin-contrib/sse v0.1.0 // indirect
7179
github.com/go-faster/city v1.0.1 // indirect
7280
github.com/go-faster/errors v0.7.1 // indirect
@@ -82,6 +90,7 @@ require (
8290
github.com/go-playground/validator/v10 v10.23.0 // indirect
8391
github.com/goccy/go-json v0.10.4 // indirect
8492
github.com/gofrs/flock v0.8.1 // indirect
93+
github.com/gogo/protobuf v1.3.2 // indirect
8594
github.com/golang/snappy v0.0.5-0.20220116011046-fa5810519dcb // indirect
8695
github.com/google/flatbuffers v25.2.10+incompatible // indirect
8796
github.com/google/uuid v1.6.0 // indirect
@@ -92,6 +101,8 @@ require (
92101
github.com/json-iterator/go v1.1.12 // indirect
93102
github.com/klauspost/compress v1.18.0 // indirect
94103
github.com/klauspost/cpuid/v2 v2.2.9 // indirect
104+
github.com/kr/pretty v0.3.1 // indirect
105+
github.com/kr/text v0.2.0 // indirect
95106
github.com/leodido/go-urn v1.4.0 // indirect
96107
github.com/magiconair/properties v1.8.10 // indirect
97108
github.com/mailru/easyjson v0.7.7 // indirect
@@ -113,6 +124,7 @@ require (
113124
github.com/prometheus/common v0.55.0 // indirect
114125
github.com/prometheus/procfs v0.15.1 // indirect
115126
github.com/rivo/uniseg v0.2.0 // indirect
127+
github.com/rogpeppe/go-internal v1.13.1 // indirect
116128
github.com/sagikazarmark/locafero v0.4.0 // indirect
117129
github.com/sagikazarmark/slog-shim v0.1.0 // indirect
118130
github.com/segmentio/asm v1.2.0 // indirect

‎go.sum‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,8 @@ github.com/cloudwego/base64x v0.1.4 h1:jwCgWpFanWmN8xoIUHa2rtzmkd5J2plF/dnLS6Xd/
6767
github.com/cloudwego/base64x v0.1.4/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w=
6868
github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg=
6969
github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
70+
github.com/cockroachdb/datadriven v1.0.3-0.20230413201302-be42291fc80f h1:otljaYPt5hWxV3MUfO5dFPFiOXg9CyG5/kCfayTqsJ4=
71+
github.com/cockroachdb/datadriven v1.0.3-0.20230413201302-be42291fc80f/go.mod h1:a9RdTaap04u637JoCzcUoIcDmvwSUtcUFtT/C3kJlTU=
7072
github.com/cockroachdb/errors v1.11.3 h1:5bA+k2Y6r+oz/6Z/RFlNeVCesGARKuC6YymtcDrbC/I=
7173
github.com/cockroachdb/errors v1.11.3/go.mod h1:m4UIW4CDjx+R5cybPsNrRbreomiFqt8o1h1wUVazSd8=
7274
github.com/cockroachdb/fifo v0.0.0-20240606204812-0bbfbd93a7ce h1:giXvy4KSc/6g/esnpM7Geqxka4WSqI1SZc7sMJFd3y4=
@@ -92,6 +94,7 @@ github.com/crate-crypto/go-ipa v0.0.0-20240724233137-53bbb0ceb27a h1:W8mUrRp6NOV
9294
github.com/crate-crypto/go-ipa v0.0.0-20240724233137-53bbb0ceb27a/go.mod h1:sTwzHBvIzm2RfVCGNEBZgRyjwK40bVoun3ZnGOCafNM=
9395
github.com/crate-crypto/go-kzg-4844 v1.1.0 h1:EN/u9k2TF6OWSHrCCDBBU6GLNMq88OspHHlMnHfoyU4=
9496
github.com/crate-crypto/go-kzg-4844 v1.1.0/go.mod h1:JolLjpSff1tCCJKaJx4psrlEdlXuJEC996PL3tTAFks=
97+
github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
9598
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
9699
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
97100
github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
@@ -132,6 +135,8 @@ github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE
132135
github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI=
133136
github.com/gin-gonic/gin v1.10.0 h1:nTuyha1TYqgedzytsKYqna+DfLos46nTv2ygFy86HFU=
134137
github.com/gin-gonic/gin v1.10.0/go.mod h1:4PMNQiOhvDRa013RKVbsiNwoyezlm2rm0uX/T7kzp5Y=
138+
github.com/go-errors/errors v1.4.2 h1:J6MZopCL4uSllY1OfXM374weqZFFItUbrImctkmUxIA=
139+
github.com/go-errors/errors v1.4.2/go.mod h1:sIVyrIiJhuEF+Pj9Ebtd6P/rEYROXFi3BopGUQ5a5Og=
135140
github.com/go-faster/city v1.0.1 h1:4WAxSZ3V2Ws4QRDrscLEDcibJY8uf41H6AhXDrNDcGw=
136141
github.com/go-faster/city v1.0.1/go.mod h1:jKcUJId49qdW3L1qKHH/3wPeUstCVpVSXTM6vO3VcTw=
137142
github.com/go-faster/errors v0.7.1 h1:MkJTnDoEdi9pDabt1dpWf7AA8/BaSYZqibYyhZ20AYg=
@@ -274,6 +279,8 @@ github.com/pelletier/go-toml/v2 v2.2.3 h1:YmeHyLY8mFWbdkNWwpr+qIL2bEqT0o95WSdkNH
274279
github.com/pelletier/go-toml/v2 v2.2.3/go.mod h1:MfCQTFTvCcUyyvvwm1+G6H/jORL20Xlb6rzQu9GuUkc=
275280
github.com/pierrec/lz4/v4 v4.1.22 h1:cKFw6uJDK+/gfw5BcDL0JL5aBsAFdsIT18eRtLj7VIU=
276281
github.com/pierrec/lz4/v4 v4.1.22/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4=
282+
github.com/pingcap/errors v0.11.4 h1:lFuQV/oaUMGcD2tqt+01ROSmJs75VG1ToEOkZIZ4nE4=
283+
github.com/pingcap/errors v0.11.4/go.mod h1:Oi8TUi2kEtXXLMJk9l1cGmz20kV3TaQ0usTwv5KuLY8=
277284
github.com/pion/dtls/v2 v2.2.7 h1:cSUBsETxepsCSFSxC3mc/aDo14qQLMSL+O6IjG28yV8=
278285
github.com/pion/dtls/v2 v2.2.7/go.mod h1:8WiMkebSHFD0T+dIU+UeBaoV7kDhOW5oDCzZ7WZ/F9s=
279286
github.com/pion/logging v0.2.2 h1:M9+AIj/+pxNsDfAT64+MAVgJO0rsyLnoJKCqf//DoeY=
@@ -284,6 +291,7 @@ github.com/pion/transport/v2 v2.2.1 h1:7qYnCBlpgSJNYMbLCKuSY9KbQdBFoETvPNETv0y4N
284291
github.com/pion/transport/v2 v2.2.1/go.mod h1:cXXWavvCnFF6McHTft3DWS9iic2Mftcz1Aq29pGcU5g=
285292
github.com/pion/transport/v3 v3.0.1 h1:gDTlPJwROfSfz6QfSi0ZmeCSkFcnWWiiR9ES0ouANiM=
286293
github.com/pion/transport/v3 v3.0.1/go.mod h1:UY7kiITrlMv7/IKgd5eTUcaahZx5oUN3l9SzK5f5xE0=
294+
github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA=
287295
github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
288296
github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
289297
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
@@ -301,6 +309,7 @@ github.com/redis/go-redis/v9 v9.12.1 h1:k5iquqv27aBtnTm2tIkROUDp8JBXhXZIVu1InSgv
301309
github.com/redis/go-redis/v9 v9.12.1/go.mod h1:huWgSWd8mW6+m0VPhJjSSQ+d6Nh1VICQ6Q5lHuCH/Iw=
302310
github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY=
303311
github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
312+
github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
304313
github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
305314
github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
306315
github.com/rs/cors v1.7.0 h1:+88SsELBHx5r+hZ8TCkggzSstaWNbDvThkVK8H6f9ik=

‎internal/common/block_failures.go‎

Lines changed: 0 additions & 14 deletions
This file was deleted.

0 commit comments

Comments
 (0)