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)
Constants ¶
This section is empty.
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 ¶ added in v0.34.0
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 ¶ added in v0.34.0
IsKnativeEventingReady will check the status conditions of the KnativeEventing and return true if the KnativeEventing is ready.
func IsKnativeServingReady ¶ added in v0.34.0
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 ¶ added in v0.34.0
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 ¶ added in v0.34.0
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 ¶ added in v0.34.0
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.
Types ¶
This section is empty.
Source Files