cache

type ClientCache struct {
	// contains filtered or unexported fields
}

type ClientCacheOpts struct {
	DialTimeout             time.Duration
	StreamTimeout           time.Duration
	ClientWaitTimeout       time.Duration
	HealthcheckInterval     time.Duration
	IdleTimeout             time.Duration
	ReconnectTimeout        time.Duration
	MaxStreamsPerConnection int64
	MaxClientPerAddress     int64

	Key              *ecdsa.PrivateKey
	ResponseCallback func(client.ResponseMetaInfo) error
	AllowExternal    bool
	DialerSource     *net.DialerSource
	RetryPolicy      *RetryPolicy
	RetryThrottling  *RetryThrottling

	Log     *logger.Logger
	Name    string
	Metrics Metrics
}

type Metrics interface {
	IncFailedHealthcheckCounter(service, address string)
}

type RetryPolicy struct {
	MaxAttempts       uint64
	InitialBackoff    time.Duration
	MaxBackoff        time.Duration
	BackoffMultiplier float64
}

type RetryThrottling struct {
	MaxTokens  int64
	TokenRatio int64
	TokenDec   int64
}