Documentation
¶
Index ¶
- Constants
- func AreDesired(desiredObject, actualObject client.Object) (bool, error)
- func AreEqual(desired, actual client.Object) (bool, error)
- func AreReady(resources ...client.Object) (bool, error)
- func Create(r workload.Reconciler, req *workload.Request, resource client.Object) error
- func EqualGVK(left, right client.Object) bool
- func EqualNamespaceName(left, right client.Object) bool
- func Get(r workload.Reconciler, req *workload.Request, resource client.Object) (client.Object, error)
- func IsReady(resource client.Object) (bool, error)
- func NamespaceForResourceIsReady(r workload.Reconciler, req *workload.Request, resource client.Object) (bool, error)
- func NeedsUpdate(r workload.Reconciler, desired, actual client.Object) (bool, error)
- func ToTyped(destination, source client.Object) error
- func ToUnstructured(resource client.Object) (*unstructured.Unstructured, error)
- func Update(r workload.Reconciler, req *workload.Request, ...) error
- type CRDResource
- type ConfigMapResource
- type DaemonSetResource
- type DeploymentResource
- type JobResource
- type NamespaceResource
- type SecretResource
- type ServiceResource
- type StatefulSetResource
- type UnknownResource
Constants ¶
const ( ConfigMapKind = "ConfigMap" ConfigMapVersion = "v1" )
const ( CustomResourceDefinitionKind = "CustomResourceDefinition" CustomResourceDefinitionVersion = "apiextensions.k8s.io/v1" )
const ( DaemonSetKind = "DaemonSet" DaemonSetVersion = "apps/v1" )
const ( DeploymentKind = "Deployment" DeploymentVersion = "apps/v1" )
const ( JobKind = "Job" JobVersion = "batch/v1" )
const ( NamespaceKind = "Namespace" NamespaceVersion = "v1" )
const ( SecretKind = "Secret" SecretVersion = "v1" )
const ( ServiceKind = "Service" ServiceVersion = "v1" )
const ( StatefulSetKind = "StatefulSet" StatefulSetVersion = "apps/v1" )
Variables ¶
This section is empty.
Functions ¶
func AreDesired ¶ added in v0.3.0
AreDesired determines if an actual resource is in a desired state based on the state of a desired resource.
func AreReady ¶
AreReady returns whether resources are ready. All resources must be ready in order to satisfy the requirement that resources are ready.
func EqualNamespaceName ¶
EqualNamespaceName will compare the namespace and name of two resource objects for equality.
func Get ¶
func Get(r workload.Reconciler, req *workload.Request, resource client.Object) (client.Object, error)
Get gets a resource.
func IsReady ¶
IsReady returns whether a specific known resource is ready. Always returns true for unknown resources so that dependency checks will not fail and reconciliation of resources can happen with errors rather than stopping entirely.
func NamespaceForResourceIsReady ¶
func NamespaceForResourceIsReady(r workload.Reconciler, req *workload.Request, resource client.Object) (bool, error)
NamespaceForResourceIsReady will check to see if the Namespace of a metadata.namespace field of a resource is ready.
func NeedsUpdate ¶
NeedsUpdate determines if a resource needs to be updated.
func ToUnstructured ¶
func ToUnstructured(resource client.Object) (*unstructured.Unstructured, error)
ToUnstructured returns an unstructured representation of a resource.
Types ¶
type CRDResource ¶
type CRDResource struct {
Object extensionsv1.CustomResourceDefinition
}
func NewCRDResource ¶
func NewCRDResource(object client.Object) (*CRDResource, error)
NewCRDResource creates and returns a new CRDResource.
func (*CRDResource) IsReady ¶
func (crd *CRDResource) IsReady() (bool, error)
IsReady performs the logic to determine if a CRD is ready.
type ConfigMapResource ¶
func NewConfigMapResource ¶
func NewConfigMapResource(object client.Object) (*ConfigMapResource, error)
NewConfigMapResource creates and returns a new ConfigMapResource.
func (*ConfigMapResource) IsReady ¶
func (configMap *ConfigMapResource) IsReady() (bool, error)
IsReady performs the logic to determine if a ConfigMap is ready.
type DaemonSetResource ¶
DaemonSetResource represents a Kubernetes Daemonset object.
func NewDaemonSetResource ¶
func NewDaemonSetResource(object client.Object) (*DaemonSetResource, error)
NewDaemonSetResource creates and returns a new DaemonSetResource.
func (*DaemonSetResource) IsReady ¶
func (daemonSet *DaemonSetResource) IsReady() (bool, error)
DaemonSetIsReady checks to see if a Daemonset is ready.
type DeploymentResource ¶
type DeploymentResource struct {
Object appsv1.Deployment
}
DeploymentResource represents a Kubernetes Deployment object.
func NewDeploymentResource ¶
func NewDeploymentResource(object client.Object) (*DeploymentResource, error)
NewDeploymentResource creates and returns a new DeploymentResource.
func (*DeploymentResource) IsReady ¶
func (deployment *DeploymentResource) IsReady() (bool, error)
IsReady performs the logic to determine if a Deployment is ready.
type JobResource ¶
JobResource represents a Kubernetes Job object.
func NewJobResource ¶
func NewJobResource(object client.Object) (*JobResource, error)
NewJobResource creates and returns a new JobResource.
func (*JobResource) IsReady ¶
func (job *JobResource) IsReady() (bool, error)
IsReady checks to see if a Job is ready.
type NamespaceResource ¶
NamespaceResource represents a Kubernetes Namespace object.
func NewNamespaceResource ¶
func NewNamespaceResource(object client.Object) (*NamespaceResource, error)
NewNamespaceResource creates and returns a new NamespaceResource.
func (*NamespaceResource) IsReady ¶
func (namespace *NamespaceResource) IsReady() (bool, error)
IsReady defines the criteria for a Namespace to be condsidered ready.
type SecretResource ¶
SecretResource represents a Kubernetes Secret object.
func NewSecretResource ¶
func NewSecretResource(object client.Object) (*SecretResource, error)
NewSecretResource creates and returns a new SecretResource.
func (*SecretResource) IsReady ¶
func (secret *SecretResource) IsReady() (bool, error)
IsReady checks to see if a Secret is ready.
type ServiceResource ¶
ServiceResource represents a Kubernetes Service object.
func NewServiceResource ¶
func NewServiceResource(object client.Object) (*ServiceResource, error)
NewServiceResource creates and returns a new ServiceResource.
func (*ServiceResource) IsReady ¶
func (service *ServiceResource) IsReady() (bool, error)
IsReady checks to see if a Service is ready.
type StatefulSetResource ¶
type StatefulSetResource struct {
Object appsv1.StatefulSet
}
StatefulSetResource represents a Kubernetes StatefulSet object.
func NewStatefulSetResource ¶
func NewStatefulSetResource(object client.Object) (*StatefulSetResource, error)
NewStatefulSetResource creates and returns a new StatefulSetResource.
func (*StatefulSetResource) IsReady ¶
func (statefulSet *StatefulSetResource) IsReady() (bool, error)
IsReady performs the logic to determine if a StatefulSet is ready.
type UnknownResource ¶
type UnknownResource struct{}
UnknownResource represents an unknown object.
func NewUnknownResource ¶
func NewUnknownResource(object client.Object) (*UnknownResource, error)
NewUnknownResource creates and returns a new UnknownResource.
func (*UnknownResource) IsReady ¶
func (unknown *UnknownResource) IsReady() (bool, error)
IsReady performs the logic to determine if an Unknown resource is ready.