worker

Documentation

Index

• type EventProcessor
• type FakeEventProcessor
  • func NewFakeProcessor(processEvent func(event events.Event) error) FakeEventProcessor
  • func (fp FakeEventProcessor) ProcessEvent(event events.Event) error
  • func (fp FakeEventProcessor) ShouldProcess(event events.Event) (bool, *string)
• type Worker
  • func (w *Worker) Run(work chan events.Event, stopChannel chan struct{})

Types

type EventProcessor

type EventProcessor interface {
	ProcessEvent(events.Event) error
	ShouldProcess(events.Event) (bool, *string)
}

EventProcessor provides a mechanism to act on events in the internal queue.

type FakeEventProcessor

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

FakeEventProcessor is fake event processor type

func NewFakeProcessor

func NewFakeProcessor(processEvent func(event events.Event) error) FakeEventProcessor

NewFakeProcessor returns a fake processor struct.

func (FakeEventProcessor) ProcessEvent

func (fp FakeEventProcessor) ProcessEvent(event events.Event) error

ProcessEvent will invoke the callback provided

func (FakeEventProcessor) ShouldProcess

func (fp FakeEventProcessor) ShouldProcess(event events.Event) (bool, *string)

ShouldProcess will return true

type Worker

type Worker struct {
	EventProcessor
}

Worker listens to the eventChannel and runs the EventProcessor.MutateAppGateway and MutateAKS for each event.

func (*Worker) Run

func (w *Worker) Run(work chan events.Event, stopChannel chan struct{})

Run starts the worker which listens for events in eventChannel; stops when stopChannel is closed.