Skip to content

Misc Cleanup #289

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 6 commits into from
Closed

Misc Cleanup #289

Show file tree
Hide file tree
Changes from 4 commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
b7b4916
Default parallel pollers
jakeloo Sep 4, 2025
00b5822
Cleanup committer block numbers initialization
jakeloo Sep 4, 2025
80399a8
Remove publisher mode, default to parallel
jakeloo Sep 4, 2025
dba7539
Gofmt
jakeloo Sep 12, 2025
3dcbcdd
Remove unused files
jakeloo Sep 12, 2025
0c901be
NumCPU -> GOMAXPROCS
jakeloo Sep 12, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 1 addition & 3 deletions cmd/root.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ func init() {
rootCmd.PersistentFlags().Int("rpc-traces-batchDelay", 0, "Milliseconds to wait between batches of traces when fetching from the RPC")
rootCmd.PersistentFlags().String("log-level", "", "Log level to use for the application")
rootCmd.PersistentFlags().Bool("log-prettify", false, "Whether to prettify the log output")
rootCmd.PersistentFlags().Int("poller-parallel-pollers", 5, "Maximum number of parallel pollers")
rootCmd.PersistentFlags().Int("poller-parallel-pollers", 0, "Maximum number of parallel pollers")
rootCmd.PersistentFlags().String("poller-s3-bucket", "", "S3 bucket for oller archive source")
rootCmd.PersistentFlags().String("poller-s3-region", "", "S3 region for poller archive source")
rootCmd.PersistentFlags().String("poller-s3-prefix", "", "S3 prefix for poller archive source")
Expand Down Expand Up @@ -173,7 +173,6 @@ func init() {
rootCmd.PersistentFlags().Bool("api-contractApiRequest-disableCompression", false, "Disable compression for contract API request")
rootCmd.PersistentFlags().Int("api-contractApiRequest-timeout", 10, "Timeout in seconds for contract API request")
rootCmd.PersistentFlags().Bool("publisher-enabled", false, "Toggle publisher")
rootCmd.PersistentFlags().String("publisher-mode", "default", "Publisher mode: default or parallel")
rootCmd.PersistentFlags().String("publisher-brokers", "", "Kafka brokers")
rootCmd.PersistentFlags().String("publisher-username", "", "Kafka username for publisher")
rootCmd.PersistentFlags().String("publisher-password", "", "Kafka password for publisher")
Expand Down Expand Up @@ -368,7 +367,6 @@ func init() {
viper.BindPFlag("api.contractApiRequest.disableCompression", rootCmd.PersistentFlags().Lookup("api-contractApiRequest-disableCompression"))
viper.BindPFlag("api.contractApiRequest.timeout", rootCmd.PersistentFlags().Lookup("api-contractApiRequest-timeout"))
viper.BindPFlag("publisher.enabled", rootCmd.PersistentFlags().Lookup("publisher-enabled"))
viper.BindPFlag("publisher.mode", rootCmd.PersistentFlags().Lookup("publisher-mode"))
viper.BindPFlag("publisher.brokers", rootCmd.PersistentFlags().Lookup("publisher-brokers"))
viper.BindPFlag("publisher.username", rootCmd.PersistentFlags().Lookup("publisher-username"))
viper.BindPFlag("publisher.password", rootCmd.PersistentFlags().Lookup("publisher-password"))
Expand Down
1 change: 0 additions & 1 deletion configs/config.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,6 @@ type EventPublisherConfig struct {

type PublisherConfig struct {
Enabled bool `mapstructure:"enabled"`
Mode string `mapstructure:"mode"`
Brokers string `mapstructure:"brokers"`
Username string `mapstructure:"username"`
Password string `mapstructure:"password"`
Expand Down
Loading