processor

Documentation

Index

• type Processor
  • func New(logger log.FieldLogger) *Processor
  • func (p *Processor) Process(ctx context.Context, gitlab *gitlab.Gitlab, ...)

Types

type Processor

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

func New

func New(logger log.FieldLogger) *Processor

New returns new Processor which handles the alert queue and retrying.

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, gitlab *gitlab.Gitlab, alertChannel chan *alertmanager.Webhook, retryLimit int, retryBackoff time.Duration)

Process processes alerts from the given channel and creates Gitlab issues from them.