Skip to content

Commit 80eea85

Browse files
committed
Set a default timeout on feeder client
1 parent c93f972 commit 80eea85

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

clients/feeder/feeder.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,11 @@ func (c *Client) WithUserAgent(ua string) *Client {
6161
return c
6262
}
6363

64+
func (c *Client) WithTimeout(t time.Duration) *Client {
65+
c.client.Timeout = t
66+
return c
67+
}
68+
6469
func ExponentialBackoff(wait time.Duration) time.Duration {
6570
return wait * 2
6671
}

node/node.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,8 @@ func New(cfg *Config, version string) (*Node, error) { //nolint:gocyclo,funlen
112112
services := make([]service.Service, 0)
113113

114114
chain := blockchain.New(database, cfg.Network, log)
115-
client := feeder.NewClient(cfg.Network.FeederURL()).WithUserAgent(ua).WithLogger(log)
115+
feederClientTimeout := 5 * time.Second
116+
client := feeder.NewClient(cfg.Network.FeederURL()).WithUserAgent(ua).WithLogger(log).WithTimeout(feederClientTimeout)
116117
synchronizer := sync.New(chain, adaptfeeder.New(client), log, cfg.PendingPollInterval)
117118
services = append(services, synchronizer)
118119
gatewayClient := gateway.NewClient(cfg.Network.GatewayURL(), log).WithUserAgent(ua)

0 commit comments

Comments
 (0)