status

Documentation

Index

• Constants
• type Client
  • func NewClient(c clientset.Interface, leaseName, leaseNamespace string, ...) *Client
  • func (c *Client) IsStatusValid(statusTimeout time.Duration) (bool, error)
  • func (c *Client) UpdateStatus() error
• type Updater
  • func NewUpdater(c clientset.Interface, statusName, statusNamespace string, ...) *Updater
  • func (su *Updater) Run(stopCh <-chan struct{})
• type Validator
  • func NewValidator(c clientset.Interface, leaseName, leaseNamespace string) Validator

Constants

const (
	// AdmissionControllerStatusName is the name of
	// the Admission Controller status object.
	AdmissionControllerStatusName = "vpa-admission-controller"
	// AdmissionControllerStatusNamespace is the namespace of
	// the Admission Controller status object.
	AdmissionControllerStatusNamespace = "kube-system"
	// AdmissionControllerStatusTimeout is a time after which
	// if not updated the Admission Controller status is no longer valid.
	AdmissionControllerStatusTimeout = 1 * time.Minute
)

Types

type Client

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

Client for the status object.

func NewClient

func NewClient(c clientset.Interface, leaseName, leaseNamespace string, leaseDuration time.Duration, holderIdentity string) *Client

NewClient returns a client for the status object.

func (*Client) IsStatusValid

func (c *Client) IsStatusValid(statusTimeout time.Duration) (bool, error)

IsStatusValid verifies if the current status object was updated before lease timing out.

func (*Client) UpdateStatus

func (c *Client) UpdateStatus() error

UpdateStatus renews status object lease. Status object will be created if it doesn't exist.

type Updater

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

Updater periodically updates status object.

func NewUpdater

func NewUpdater(c clientset.Interface, statusName, statusNamespace string,
	updateInterval time.Duration, holderIdentity string) *Updater

NewUpdater returns a new status updater.

func (*Updater) Run

func (su *Updater) Run(stopCh <-chan struct{})

Run starts status updates.

type Validator

type Validator interface {
	IsStatusValid(statusTimeout time.Duration) (bool, error)
}

Validator for the status object.

func NewValidator

func NewValidator(c clientset.Interface, leaseName, leaseNamespace string) Validator

NewValidator returns a validator for the status object.