strategy

Documentation

Index

• type RandomizedDelay
  • func InitRandomizedDelay(ctx context.Context, maxDelay int, dSettings *internal.DefaultSettings, ...) *RandomizedDelay
  • func (d RandomizedDelay) Run(ctx context.Context) error

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.