resilience

package

v0.4.0 Latest Latest Go to latest Published: Jul 16, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var ErrCircuitOpen = errors.New("circuit breaker is open")

This section is empty.

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

func NewCircuitBreaker(inner core.Action, config CircuitBreakerConfig) *CircuitBreaker

NewCircuitBreaker creates a new CircuitBreaker adapter.

func (c *CircuitBreaker) Execute(ctx context.Context, env core.Envelope) (core.Envelope, error)

Execute runs the inner action if the circuit is closed or half-open.

func (c *CircuitBreaker) Metadata() core.ActionMetadata

Metadata delegates to the inner action's Metadata.

type CircuitBreakerConfig struct {
	FailureThreshold uint64
	ResetTimeout     time.Duration
}

type State int

const (
	StateClosed State = iota
	StateOpen
	StateHalfOpen
)