circuitbreaker

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

type Config struct {
	// Name identifies this circuit breaker
	Name string

	// MaxFailures is the number of failures before opening the circuit
	MaxFailures int

	// SuccessThreshold is the number of successes needed to close from half-open
	SuccessThreshold int

	// Timeout is how long the circuit stays open before testing
	Timeout time.Duration

	// MaxConcurrentInHalfOpen is the max concurrent requests when half-open
	MaxConcurrentInHalfOpen int

	// OnStateChange is called when the state changes
	OnStateChange func(name string, from, to State)
}

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

type State int

type Stats struct {
	Name            string    `json:"name"`
	State           string    `json:"state"`
	Failures        int       `json:"failures"`
	Successes       int       `json:"successes"`
	LastFailure     time.Time `json:"last_failure,omitzero"`
	LastStateChange time.Time `json:"last_state_change"`
	Generation      uint64    `json:"generation"`
}