rollout

Documentation

Overview

Package rollout implements waiting for rollout completion of a set of objects.

Index

• func WaitUntilComplete(objects []model.K8sMeta, wp WatchProvider, opts WaitOptions) (finalErr error)
• type StatusListener
• type WaitOptions
• type WatchProvider

Functions

func WaitUntilComplete

func WaitUntilComplete(objects []model.K8sMeta, wp WatchProvider, opts WaitOptions) (finalErr error)

WaitUntilComplete waits for the supplied objects to be ready and returns when they are. An error is returned if the function times out before all objects are ready. Any status listener provider is notified of individual status changes and errors during the wait. Individual watches having errors are turned into a aggregate error.

Types

type StatusListener

type StatusListener interface {
	OnInit(objects []model.K8sMeta)                              // the set of objects that are being monitored
	OnStatusChange(object model.K8sMeta, rs types.RolloutStatus) // status for specified object
	OnError(object model.K8sMeta, err error)                     // watch error of some kind for specified object
	OnEnd(err error)                                             // end of status updates with final error
}

StatusListener receives status update callbacks.

type WaitOptions

type WaitOptions struct {
	Listener StatusListener
	Timeout  time.Duration
}

WaitOptions are options to the wait function.

type WatchProvider

type WatchProvider func(obj model.K8sMeta) (watch.Interface, error)

WatchProvider provides a resource interface for a specific object type and namespace.