k8s

Documentation

Index

• Constants
• func DeploymentLocator(ctx model.SessionContext, ref model.Ref, store model.LocatorStatusStore, ...) error
• func DeploymentModificator(engine template.Engine) model.Modificator
• func DeploymentRegistrar(engine template.Engine) model.ModificatorRegistrar
• func ServiceLocator(ctx model.SessionContext, ref model.Ref, store model.LocatorStatusStore, ...) error
• func ServiceModificator(ctx model.SessionContext, ref model.Ref, store model.LocatorStatusStore, ...)
• func ServiceRegistrar() (client.Object, model.Modificator)
• type AssumeOperatorInstalled
  • func (AssumeOperatorInstalled) CheckCRD() (bool, error)
• type ClusterVerifier
  • func (v *ClusterVerifier) CheckCRD() (bool, error)
• type InstallationVerifier

Constants

const (
	// DeploymentKind is the k8s Kind for a Deployment.
	DeploymentKind = "Deployment"
)

const (
	// ServiceKind is the k8s Kind for a Service.
	ServiceKind = "Service"
)

Functions

func DeploymentLocator

func DeploymentLocator(ctx model.SessionContext, ref model.Ref, store model.LocatorStatusStore, report model.LocatorStatusReporter) error

DeploymentLocator attempts to locate a Deployment kind based on Ref name.

func DeploymentModificator

func DeploymentModificator(engine template.Engine) model.Modificator

DeploymentModificator attempts to clone the located Deployment.

func DeploymentRegistrar

func DeploymentRegistrar(engine template.Engine) model.ModificatorRegistrar

func ServiceLocator

func ServiceLocator(ctx model.SessionContext, ref model.Ref, store model.LocatorStatusStore, report model.LocatorStatusReporter) error

ServiceLocator attempts to locate the Services for the target Deployment/DeploymentConfig.

func ServiceModificator

func ServiceModificator(ctx model.SessionContext, ref model.Ref, store model.LocatorStatusStore, report model.ModificatorStatusReporter)

ServiceModificator will set a located service to modification status true.

func ServiceRegistrar

func ServiceRegistrar() (client.Object, model.Modificator)

Types

type AssumeOperatorInstalled

type AssumeOperatorInstalled struct{}

AssumeOperatorInstalled is used for testing where we simply assume CRD is always installed. This is in particular useful as test double where cluster is not involved at all.

func (AssumeOperatorInstalled) CheckCRD

func (AssumeOperatorInstalled) CheckCRD() (bool, error)

type ClusterVerifier

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

func (*ClusterVerifier) CheckCRD

func (v *ClusterVerifier) CheckCRD() (bool, error)

type InstallationVerifier

type InstallationVerifier interface {
	CheckCRD() (bool, error)
}