health

Documentation

Index

• func HasHealthCondition(wle *config.Config) bool
• func IsEligibleForHealthStatusUpdates(wle *config.Config) bool
• type Controller
  • func NewController(stateStore *state.Store, maxRetries int) *Controller
  • func (c *Controller) QueueWorkloadEntryHealth(proxy *model.Proxy, event HealthEvent)
  • func (c *Controller) Run(stop <-chan struct{})
• type HealthCondition
• type HealthEvent

Functions

func HasHealthCondition

func HasHealthCondition(wle *config.Config) bool

HasHealthCondition returns true if a given WorkloadEntry has ConditionHealthy condition.

func IsEligibleForHealthStatusUpdates

func IsEligibleForHealthStatusUpdates(wle *config.Config) bool

IsEligibleForHealthStatusUpdates returns true if a given WorkloadEntry is allowed to receive health status updates sent by an Istio Proxy.

Consider a workload eligible for health status updates as long as the WorkloadEntryHealthCheckAnnotation is present (no matter what the value is). In case the annotation is present but the value is not "true", the proxy should be allowed to send health status updates, config health condition should be updated accordingly, however reported health status should not come into effect.

Types

type Controller

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

Controller knows how to update health status of a workload.

func NewController

func NewController(stateStore *state.Store, maxRetries int) *Controller

NewController returns a new Controller instance.

func (*Controller) QueueWorkloadEntryHealth

func (c *Controller) QueueWorkloadEntryHealth(proxy *model.Proxy, event HealthEvent)

QueueWorkloadEntryHealth enqueues the associated WorkloadEntries health status.

func (*Controller) Run

func (c *Controller) Run(stop <-chan struct{})

type HealthCondition

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

type HealthEvent

type HealthEvent struct {
	// whether or not the agent thought the target is healthy
	Healthy bool `json:"healthy,omitempty"`
	// error message propagated
	Message string `json:"errMessage,omitempty"`
}