state

Documentation

Index

• type ActionState
  • func NewState() *ActionState
  • func (s *ActionState) Add(countermeasure *v1alpha1.CounterMeasure) error
  • func (s *ActionState) CounterMeasureEnd(event events.Event, key manager.ObjectKey)
  • func (s *ActionState) CounterMeasureStart(event events.Event, key manager.ObjectKey)
  • func (s *ActionState) GetCounterMeasure(key manager.ObjectKey) *Entry
  • func (s *ActionState) IsDeployed(key manager.ObjectKey) bool
  • func (s *ActionState) IsRunning(key manager.ObjectKey) bool
  • func (s *ActionState) Remove(name types.NamespacedName) error
• type ActiveCounterMeasures
• type Entry
  • func (e *Entry) IsSuppressed(event events.Event) bool
• type RunningSet

Types

type ActionState

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

func NewState

func NewState() *ActionState

func (*ActionState) Add

func (s *ActionState) Add(countermeasure *v1alpha1.CounterMeasure) error

Add adds a new CounterMeasure entry

func (*ActionState) CounterMeasureEnd

func (s *ActionState) CounterMeasureEnd(event events.Event, key manager.ObjectKey)

CounterMeasureEnd record that a Countermeasure has ended.

func (*ActionState) CounterMeasureStart

func (s *ActionState) CounterMeasureStart(event events.Event, key manager.ObjectKey)

CounterMeasureStart record the start of a countermeasure for an event.

func (*ActionState) GetCounterMeasure

func (s *ActionState) GetCounterMeasure(key manager.ObjectKey) *Entry

GetCounterMeasures return all CounterMeasure entries that subscribe to the named event.

func (*ActionState) IsDeployed

func (s *ActionState) IsDeployed(key manager.ObjectKey) bool

IsDeployed is the countermeasure with this ObjectKey deployed, this will check the Generation as well for the exact version.

func (*ActionState) IsRunning

func (s *ActionState) IsRunning(key manager.ObjectKey) bool

func (*ActionState) Remove

func (s *ActionState) Remove(name types.NamespacedName) error

Remove delete a CounterMeasure using the NamespaceName

type ActiveCounterMeasures

type ActiveCounterMeasures map[manager.ObjectKey]*Entry

type Entry

type Entry struct {
	sync.Mutex

	Name           string
	Countermeasure *v1alpha1.CounterMeasure
	// contains filtered or unexported fields
}

func (*Entry) IsSuppressed

func (e *Entry) IsSuppressed(event events.Event) bool

type RunningSet

type RunningSet map[manager.ObjectKey]struct{}