readiness

Documentation

Index

• Constants
• func DecodeProbe(jsonProbe string) (*corev1.Probe, error)
• func EncodeProbe(rp *corev1.Probe) (string, error)
• type Probe
  • func NewProbe(v1p *corev1.Probe) *Probe
  • func (p *Probe) Count() int32
  • func (p *Probe) IsAggressive() bool
  • func (p *Probe) ProbeContainer() bool

Constants

const (

	// PollTimeout is set equal to the queue-proxy's ExecProbe timeout to take
	// advantage of the full window
	PollTimeout = 10 * time.Second
)

Functions

func DecodeProbe

func DecodeProbe(jsonProbe string) (*corev1.Probe, error)

DecodeProbe takes a json serialised *corev1.Probe and returns a Probe or an error.

func EncodeProbe

func EncodeProbe(rp *corev1.Probe) (string, error)

EncodeProbe takes *corev1.Probe object and returns marshalled Probe JSON string and an error.

Types

type Probe

type Probe struct {
	*corev1.Probe
	// contains filtered or unexported fields
}

Probe wraps a corev1.Probe along with a logger and a count of consecutive, successful probes

func NewProbe

func NewProbe(v1p *corev1.Probe) *Probe

NewProbe returns a pointer a new Probe

func (*Probe) Count

func (p *Probe) Count() int32

Count function fetches current probe count

func (*Probe) IsAggressive

func (p *Probe) IsAggressive() bool

IsAggressive indicates whether the Knative probe with aggressive retries should be used.

func (*Probe) ProbeContainer

func (p *Probe) ProbeContainer() bool

ProbeContainer executes the defined Probe against the user-container