Skip to content

Commit 4f5b3bb

Browse files
Fix autoclaim defaults for auctioneer
1 parent a3b90fa commit 4f5b3bb

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

timeboost/auctioneer.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,9 @@ var TestAuctioneerServerConfig = AuctioneerServerConfig{
105105
func AuctioneerServerConfigAddOptions(prefix string, f *pflag.FlagSet) {
106106
f.Bool(prefix+".enable", DefaultAuctioneerServerConfig.Enable, "enable auctioneer server")
107107
f.String(prefix+".redis-url", DefaultAuctioneerServerConfig.RedisURL, "url of redis server to receive bids from bid validators")
108-
pubsub.ConsumerConfigAddOptions(prefix+".consumer-config", f)
108+
// Use auctioneer-specific defaults for consumer config
109+
f.Duration(prefix+".consumer-config.response-entry-timeout", DefaultAuctioneerConsumerConfig.ResponseEntryTimeout, "timeout for response entry")
110+
f.Duration(prefix+".consumer-config.idletime-to-autoclaim", DefaultAuctioneerConsumerConfig.IdletimeToAutoclaim, "After a message spends this amount of time in PEL (Pending Entries List i.e claimed by another consumer but not Acknowledged) it will be allowed to be autoclaimed by other consumers")
109111
f.Duration(prefix+".stream-timeout", DefaultAuctioneerServerConfig.StreamTimeout, "Timeout on polling for existence of redis streams")
110112
genericconf.WalletConfigAddOptions(prefix+".wallet", f, "wallet for auctioneer server")
111113
f.String(prefix+".sequencer-endpoint", DefaultAuctioneerServerConfig.SequencerEndpoint, "sequencer RPC endpoint")

0 commit comments

Comments
 (0)