podreadiness

Documentation

Index

• func SetCondition(condChan chan<- v1.PodCondition, condType RTEConditionType, ...)
• type ConditionInjector
  • func NewConditionInjector(cs kubernetes.Interface) (*ConditionInjector, error)
  • func (ci *ConditionInjector) Inject(cond v1.PodCondition) error
  • func (ci *ConditionInjector) Run(condChan <-chan v1.PodCondition)
• type RTEConditionType

Functions

func SetCondition

func SetCondition(condChan chan<- v1.PodCondition, condType RTEConditionType, condStatus v1.ConditionStatus)

Types

type ConditionInjector

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

func NewConditionInjector

func NewConditionInjector(cs kubernetes.Interface) (*ConditionInjector, error)

func (*ConditionInjector) Inject

func (ci *ConditionInjector) Inject(cond v1.PodCondition) error

func (*ConditionInjector) Run

func (ci *ConditionInjector) Run(condChan <-chan v1.PodCondition)

type RTEConditionType

type RTEConditionType string

RTEConditionType is a valid value for PodCondition.Type

const (
	// PodresourcesFetched means that resources scanned successfully.
	PodresourcesFetched RTEConditionType = "PodresourcesFetched"
	// NodeTopologyUpdated means that noderesourcetopology objects updated successfully.
	NodeTopologyUpdated RTEConditionType = "NodeTopologyUpdated"
)

These are valid conditions of RTE pod.