circuitbreaker

Documentation

Index

• Constants
• type CBObservability
  • func NewCBObservability(registry *prometheus.Registry, log *slog.Logger, name string, flow string) *CBObservability
  • func (cbO11y *CBObservability) SetCBClosed()
  • func (cbO11y *CBObservability) SetCBOpen()
• type CircuitBreaker
• type DummyCircuitBreaker
  • func NewDummyCircuitBreaker() *DummyCircuitBreaker
  • func (cb *DummyCircuitBreaker) Execute(f func() (interface{}, error)) (interface{}, error)
• type DummyTwoStepCircuitBreaker
  • func NewDummyTwoStepCircuitBreaker() *DummyTwoStepCircuitBreaker
  • func (cb *DummyTwoStepCircuitBreaker) Allow() (func(bool), error)
• type TwoStepCircuitBreaker

Constants

const (
	FlowMetricKey string = "flow"
	NameMetricKey string = "name"
)

Types

type CBObservability

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

func NewCBObservability

func NewCBObservability(
	registry *prometheus.Registry,
	log *slog.Logger,
	name string,
	flow string,
) *CBObservability

func (*CBObservability) SetCBClosed

func (cbO11y *CBObservability) SetCBClosed()

func (*CBObservability) SetCBOpen

func (cbO11y *CBObservability) SetCBOpen()

type CircuitBreaker

type CircuitBreaker interface {
	Execute(func() (interface{}, error)) (interface{}, error)
}

type DummyCircuitBreaker

type DummyCircuitBreaker struct{}

A Circuitbreaker that accepts all requests and never trips. Useful in cases where you want to not have a CB.

func NewDummyCircuitBreaker

func NewDummyCircuitBreaker() *DummyCircuitBreaker

func (*DummyCircuitBreaker) Execute

func (cb *DummyCircuitBreaker) Execute(f func() (interface{}, error)) (interface{}, error)

type DummyTwoStepCircuitBreaker

type DummyTwoStepCircuitBreaker struct{}

A Circuitbreaker that accepts all requests and never trips. Useful in cases where you want to not have a CB.

func NewDummyTwoStepCircuitBreaker

func NewDummyTwoStepCircuitBreaker() *DummyTwoStepCircuitBreaker

func (*DummyTwoStepCircuitBreaker) Allow

func (cb *DummyTwoStepCircuitBreaker) Allow() (func(bool), error)

type TwoStepCircuitBreaker

type TwoStepCircuitBreaker interface {
	Allow() (func(bool), error)
}