breaker

Documentation

Index

• type Breaker
  • func New(on bool) *Breaker
  • func (breaker *Breaker) DoIfBreakerOn(ctx context.Context, d func(ctx context.Context)) bool
  • func (breaker *Breaker) IsOn() bool
  • func (breaker *Breaker) Off(reason string)
  • func (breaker *Breaker) OffChan() <-chan struct{}
  • func (breaker *Breaker) On(reason string)
  • func (breaker *Breaker) OnChan() <-chan struct{}
  • func (breaker *Breaker) WaitBreakerOn(ctx context.Context, d func(ctx context.Context) (doAgain bool)) int

Types

type Breaker

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

func New

func New(on bool) *Breaker

func (*Breaker) DoIfBreakerOn

func (breaker *Breaker) DoIfBreakerOn(ctx context.Context, d func(ctx context.Context)) bool

func (*Breaker) IsOn

func (breaker *Breaker) IsOn() bool

func (*Breaker) Off

func (breaker *Breaker) Off(reason string)

func (*Breaker) OffChan

func (breaker *Breaker) OffChan() <-chan struct{}

func (*Breaker) On

func (breaker *Breaker) On(reason string)

func (*Breaker) OnChan

func (breaker *Breaker) OnChan() <-chan struct{}

func (*Breaker) WaitBreakerOn

func (breaker *Breaker) WaitBreakerOn(ctx context.Context, d func(ctx context.Context) (doAgain bool)) int

ctn is continue