install

Documentation

Index

• Variables
• func IsKnativeDeploymentReady(dpList *v1.DeploymentList, expectedDeployments []string, version string, ...) (bool, error)
• func IsKnativeEventingReady(s *v1beta1.KnativeEventing, version string, err error) (bool, error)
• func IsKnativeServingReady(s *v1beta1.KnativeServing, version string, err error) (bool, error)
• func NewInstallCommand(p *pkg.OperatorParams) *cobra.Command
• func RunInstallationCommand(installFlags *installCmdFlags, p *pkg.OperatorParams) error
• func WaitForKnativeDeploymentState(client kubernetes.Interface, namespace string, version string, ...) error
• func WaitForKnativeEventingState(clients operatorv1beta1.KnativeEventingInterface, name string, version string, ...) (*v1beta1.KnativeEventing, error)
• func WaitForKnativeServingState(clients operatorv1beta1.KnativeServingInterface, name string, version string, ...) (*v1beta1.KnativeServing, error)

Variables

var (
	ServingKeyDeployments  = []string{"activator", "autoscaler", "autoscaler-hpa", "controller", "webhook"}
	EventingKeyDeployments = []string{"eventing-controller", "eventing-webhook", "imc-controller", "imc-dispatcher",
		"mt-broker-controller", "mt-broker-filter", "mt-broker-ingress", "pingsource-mt-adapter"}
	// Interval specifies the time between two polls.
	Interval = 10 * time.Second
	// Timeout specifies the timeout for the function PollImmediate to reach a certain status.
	Timeout = 5 * time.Minute
)

Functions

func IsKnativeDeploymentReady

func IsKnativeDeploymentReady(dpList *v1.DeploymentList, expectedDeployments []string, version string, err error) (bool, error)

IsKnativeDeploymentReady will check the status conditions of the deployments and return true if the deployments meet the desired status.

func IsKnativeEventingReady

func IsKnativeEventingReady(s *v1beta1.KnativeEventing, version string, err error) (bool, error)

IsKnativeEventingReady will check the status conditions of the KnativeEventing and return true if the KnativeEventing is ready.

func IsKnativeServingReady

func IsKnativeServingReady(s *v1beta1.KnativeServing, version string, err error) (bool, error)

IsKnativeServingReady will check the status conditions of the KnativeServing and return true if the KnativeServing is ready.

func NewInstallCommand

func NewInstallCommand(p *pkg.OperatorParams) *cobra.Command

NewInstallCommand represents the install commands for the operation

func RunInstallationCommand

func RunInstallationCommand(installFlags *installCmdFlags, p *pkg.OperatorParams) error

func WaitForKnativeDeploymentState

func WaitForKnativeDeploymentState(client kubernetes.Interface, namespace string, version string, expectedDeployments []string,
	inState func(deps *v1.DeploymentList, expectedDeployments []string, version string, err error) (bool, error)) error

WaitForKnativeDeploymentState polls the status of the Knative deployments every `interval` until `inState` returns `true` indicating the deployments match the desired deployments.

func WaitForKnativeEventingState

func WaitForKnativeEventingState(clients operatorv1beta1.KnativeEventingInterface, name string, version string,
	inState func(s *v1beta1.KnativeEventing, version string, err error) (bool, error)) (*v1beta1.KnativeEventing, error)

WaitForKnativeEventingState polls the status of the KnativeEventing called name from client every `interval` until `inState` returns `true` indicating it is done, returns an error or timeout.

func WaitForKnativeServingState

func WaitForKnativeServingState(clients operatorv1beta1.KnativeServingInterface, name string, version string,
	inState func(s *v1beta1.KnativeServing, version string, err error) (bool, error)) (*v1beta1.KnativeServing, error)

WaitForKnativeServingState polls the status of the KnativeServing called name from client every `interval` until `inState` returns `true` indicating it is done, returns an error or timeout.