strategy

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Mar 2, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RandomizedDelay

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

func InitRandomizedDelay

func InitRandomizedDelay(ctx context.Context, maxDelay int,
	dSettings *internal.DefaultSettings, k8sClient k8sClient) *RandomizedDelay

InitRandomizedDelay initializes RandomizedDelay struct.

func (RandomizedDelay) Run

func (d RandomizedDelay) Run(ctx context.Context) error

Run requests k8s api to retrieve pods with an age older than the ttl. It sends pods' name to an internal channel. The sending action isn't blocking.

Jump to

Keyboard shortcuts

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