stages

Documentation

Index

• type Action
• type PipelineAndStateTimestampCoordinationStage
  • func NewPipelineAndStateTimestampCoordinationStage(l notify.NotificationLog, recv *nflogpb.Receiver, action Action) *PipelineAndStateTimestampCoordinationStage
  • func (n *PipelineAndStateTimestampCoordinationStage) Exec(ctx context.Context, l log.Logger, alerts ...*types.Alert) (context.Context, []*types.Alert, error)

Types

type Action

type Action string

const (
	Disabled     Action = "disabled"
	LogOnly      Action = "log-only"
	StopPipeline Action = "stop-pipeline"
)

type PipelineAndStateTimestampCoordinationStage

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

func NewPipelineAndStateTimestampCoordinationStage

func NewPipelineAndStateTimestampCoordinationStage(l notify.NotificationLog, recv *nflogpb.Receiver, action Action) *PipelineAndStateTimestampCoordinationStage

func (*PipelineAndStateTimestampCoordinationStage) Exec

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

Exec implements the Stage interface.