readiness

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 16, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (

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

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL