updater

Documentation

Index

• type Updater
  • func NewUpdater(cfg UpdaterConfig) *Updater
  • func (u *Updater) GetUpdaterChannel() chan event.Event
  • func (u *Updater) ProcessUpdate(e *event.EventUpdate) error
  • func (u *Updater) SetAckChannel(ch chan event.Event)
  • func (u *Updater) Start(ctx context.Context) error
• type UpdaterConfig

Types

type Updater

type Updater struct {
	*config.ProgressTracker
	// contains filtered or unexported fields
}

func NewUpdater

func NewUpdater(cfg UpdaterConfig) *Updater

func (*Updater) GetUpdaterChannel

func (u *Updater) GetUpdaterChannel() chan event.Event

GetUpdaterChannel returns the channel on which the updater listenens to update resuests

func (*Updater) ProcessUpdate

func (u *Updater) ProcessUpdate(e *event.EventUpdate) error

func (*Updater) SetAckChannel

func (u *Updater) SetAckChannel(ch chan event.Event)

SetAckChannel sets the channel to send acks to the operator.

func (*Updater) Start

func (u *Updater) Start(ctx context.Context) error

type UpdaterConfig

type UpdaterConfig struct {
	Manager manager.Manager
	Logger  logr.Logger
}