stages

Documentation

Index

• type PeerInfo
• type WaitStage
  • func NewWaitStage(p PeerInfo, peerTimeout time.Duration) *WaitStage
  • func (ws *WaitStage) Exec(ctx context.Context, l log.Logger, alerts ...*types.Alert) (context.Context, []*types.Alert, error)

Types

type PeerInfo

type PeerInfo interface {
	Position() int
}

type WaitStage

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

WaitStage waits for a certain amount of time before continuing or until the context is done.

func NewWaitStage

func NewWaitStage(p PeerInfo, peerTimeout time.Duration) *WaitStage

NewWaitStage returns a new WaitStage.

func (*WaitStage) Exec

func (ws *WaitStage) Exec(ctx context.Context, l log.Logger, alerts ...*types.Alert) (context.Context, []*types.Alert, error)

Exec implements the Stage interface.