resilience

Documentation

Index

• type CircuitBreaker
  • func (cb *CircuitBreaker) Execute(ctx context.Context, request *proto.CircuitBreakerRequest) (*proto.CircuitBreakerResponse, error)
• type ResilienceManager
  • func (rm *ResilienceManager) ManageResilience(ctx context.Context, request *proto.ResilienceManagementRequest) (*proto.ResilienceManagementResponse, error)
• type State

Types

type CircuitBreaker

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

func (*CircuitBreaker) Execute

func (cb *CircuitBreaker) Execute(
	ctx context.Context,
	request *proto.CircuitBreakerRequest,
) (*proto.CircuitBreakerResponse, error)

type ResilienceManager

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

func (*ResilienceManager) ManageResilience

func (rm *ResilienceManager) ManageResilience(
	ctx context.Context,
	request *proto.ResilienceManagementRequest,
) (*proto.ResilienceManagementResponse, error)

type State

type State int

const (
	StateClosed State = iota
	StateOpen
	StateHalfOpen
)