throttler

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

type BreakerParams struct {
	QueueDepth      int
	MaxConcurrency  int
	InitialCapacity int
	Logger          *zap.Logger
}

type Params struct {
	QueueRetryDuration      time.Duration
	TrafficReEnableDuration time.Duration
	K8sUtil                 *k8shelper.Ops
	QueueDepth              int
	MaxConcurrency          int
	InitialCapacity         int
	Logger                  *zap.Logger
}

type RoundTripperFunc func(*http.Request) (*http.Response, error)

type Throttler struct {
	TrafficReEnableDuration time.Duration
	// contains filtered or unexported fields
}