http

Documentation

Index

• type Circuit
  • func NewCircuit(c CircuitConfig) *Circuit
  • func (c *Circuit) Do(command string, fu CircuitFunc, fallback func(error) error, ...) error
  • func (c *Circuit) DoR(command string, fu CircuitFunc, fallback func(error) error, retry int, ...) error
• type CircuitConfig
• type CircuitErrorFilter
• type CircuitFunc

Types

type Circuit

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

func NewCircuit

func NewCircuit(c CircuitConfig) *Circuit

func (*Circuit) Do

func (c *Circuit) Do(command string, fu CircuitFunc, fallback func(error) error, fi ...CircuitErrorFilter) error

func (*Circuit) DoR

func (c *Circuit) DoR(
	command string,
	fu CircuitFunc,
	fallback func(error) error,
	retry int,
	delay time.Duration,
	fi ...CircuitErrorFilter,
) error

type CircuitConfig

type CircuitConfig struct {
	Name                   string
	Timeout                int
	MaxConcurrentRequests  int
	ErrorPercentThreshold  int
	RequestVolumeThreshold int
	SleepWindow            int
	Commands               []string
}

type CircuitErrorFilter

type CircuitErrorFilter func(error) (bool, error)

type CircuitFunc

type CircuitFunc func() error