fluxsync

package
v0.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 15, 2023 License: MPL-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RequestReconciliation

func RequestReconciliation(ctx context.Context, k client.Client, name client.ObjectKey, gvk schema.GroupVersionKind) error

RequestReconciliation sets the annotations of an object so that the flux controller(s) will force a reconciliation. Take straight from the flux CLI source: https://github.com/fluxcd/flux2/blob/cb53243fc11de81de3a34616d14322d66573aa65/cmd/flux/reconcile.go#L155

func WaitForSync

func WaitForSync(ctx context.Context, c client.Client, key client.ObjectKey, obj Reconcilable) error

WaitForSync polls the k8s API until the resources is sync'd, and times out eventually.

Types

type Automation

type Automation interface {
	Reconcilable
	SourceRef() SourceRef
}

type BucketAdapter

type BucketAdapter struct {
	*sourcev1.Bucket
}

func (BucketAdapter) AsClientObject

func (obj BucketAdapter) AsClientObject() client.Object

func (BucketAdapter) DeepCopyClientObject

func (obj BucketAdapter) DeepCopyClientObject() client.Object

func (BucketAdapter) GetLastHandledReconcileRequest

func (obj BucketAdapter) GetLastHandledReconcileRequest() string

func (BucketAdapter) GroupVersionKind

func (obj BucketAdapter) GroupVersionKind() schema.GroupVersionKind

func (BucketAdapter) SetSuspended

func (obj BucketAdapter) SetSuspended(suspend bool)

type GitRepositoryAdapter

type GitRepositoryAdapter struct {
	*sourcev1.GitRepository
}

func (GitRepositoryAdapter) AsClientObject

func (obj GitRepositoryAdapter) AsClientObject() client.Object

func (GitRepositoryAdapter) DeepCopyClientObject

func (obj GitRepositoryAdapter) DeepCopyClientObject() client.Object

func (GitRepositoryAdapter) GetLastHandledReconcileRequest

func (obj GitRepositoryAdapter) GetLastHandledReconcileRequest() string

func (GitRepositoryAdapter) GroupVersionKind

func (obj GitRepositoryAdapter) GroupVersionKind() schema.GroupVersionKind

func (GitRepositoryAdapter) SetSuspended

func (obj GitRepositoryAdapter) SetSuspended(suspend bool)

type HelmChartAdapter

type HelmChartAdapter struct {
	*sourcev1.HelmChart
}

func (HelmChartAdapter) AsClientObject

func (obj HelmChartAdapter) AsClientObject() client.Object

func (HelmChartAdapter) DeepCopyClientObject

func (obj HelmChartAdapter) DeepCopyClientObject() client.Object

func (HelmChartAdapter) GetLastHandledReconcileRequest

func (obj HelmChartAdapter) GetLastHandledReconcileRequest() string

func (HelmChartAdapter) GroupVersionKind

func (obj HelmChartAdapter) GroupVersionKind() schema.GroupVersionKind

func (HelmChartAdapter) SetSuspended

func (obj HelmChartAdapter) SetSuspended(suspend bool)

type HelmReleaseAdapter

type HelmReleaseAdapter struct {
	*helmv2.HelmRelease
}

func (HelmReleaseAdapter) AsClientObject

func (obj HelmReleaseAdapter) AsClientObject() client.Object

func (HelmReleaseAdapter) DeepCopyClientObject

func (obj HelmReleaseAdapter) DeepCopyClientObject() client.Object

func (HelmReleaseAdapter) GetLastHandledReconcileRequest

func (obj HelmReleaseAdapter) GetLastHandledReconcileRequest() string

func (HelmReleaseAdapter) GroupVersionKind

func (obj HelmReleaseAdapter) GroupVersionKind() schema.GroupVersionKind

func (HelmReleaseAdapter) SetSuspended

func (obj HelmReleaseAdapter) SetSuspended(suspend bool)

func (HelmReleaseAdapter) SourceRef

func (obj HelmReleaseAdapter) SourceRef() SourceRef

type HelmRepositoryAdapter

type HelmRepositoryAdapter struct {
	*sourcev1.HelmRepository
}

func (HelmRepositoryAdapter) AsClientObject

func (obj HelmRepositoryAdapter) AsClientObject() client.Object

func (HelmRepositoryAdapter) DeepCopyClientObject

func (obj HelmRepositoryAdapter) DeepCopyClientObject() client.Object

func (HelmRepositoryAdapter) GetLastHandledReconcileRequest

func (obj HelmRepositoryAdapter) GetLastHandledReconcileRequest() string

func (HelmRepositoryAdapter) GroupVersionKind

func (obj HelmRepositoryAdapter) GroupVersionKind() schema.GroupVersionKind

func (HelmRepositoryAdapter) SetSuspended

func (obj HelmRepositoryAdapter) SetSuspended(suspend bool)

type KustomizationAdapter

type KustomizationAdapter struct {
	*kustomizev1.Kustomization
}

func (KustomizationAdapter) AsClientObject

func (obj KustomizationAdapter) AsClientObject() client.Object

func (KustomizationAdapter) DeepCopyClientObject

func (obj KustomizationAdapter) DeepCopyClientObject() client.Object

func (KustomizationAdapter) GetLastHandledReconcileRequest

func (obj KustomizationAdapter) GetLastHandledReconcileRequest() string

func (KustomizationAdapter) GroupVersionKind

func (obj KustomizationAdapter) GroupVersionKind() schema.GroupVersionKind

func (KustomizationAdapter) SetSuspended

func (obj KustomizationAdapter) SetSuspended(suspend bool)

func (KustomizationAdapter) SourceRef

func (obj KustomizationAdapter) SourceRef() SourceRef

type OCIRepositoryAdapter

type OCIRepositoryAdapter struct {
	*sourcev1.OCIRepository
}

func (OCIRepositoryAdapter) AsClientObject

func (obj OCIRepositoryAdapter) AsClientObject() client.Object

func (OCIRepositoryAdapter) DeepCopyClientObject

func (obj OCIRepositoryAdapter) DeepCopyClientObject() client.Object

func (OCIRepositoryAdapter) GetLastHandledReconcileRequest

func (obj OCIRepositoryAdapter) GetLastHandledReconcileRequest() string

func (OCIRepositoryAdapter) GroupVersionKind

func (obj OCIRepositoryAdapter) GroupVersionKind() schema.GroupVersionKind

func (OCIRepositoryAdapter) SetSuspended

func (obj OCIRepositoryAdapter) SetSuspended(suspend bool)

type Reconcilable

type Reconcilable interface {
	client.Object
	meta.ObjectWithConditions
	GetAnnotations() map[string]string
	SetAnnotations(map[string]string)
	GetLastHandledReconcileRequest() string
	AsClientObject() client.Object
	GroupVersionKind() schema.GroupVersionKind
	SetSuspended(suspend bool)
	DeepCopyClientObject() client.Object
}

Reconcilable represents a Kubernetes object that Flux can reconcile

func NewReconcileable

func NewReconcileable(obj client.Object) Reconcilable

func ToReconcileable

func ToReconcileable(kind string) (client.ObjectList, Reconcilable, error)

type SourceRef

type SourceRef interface {
	APIVersion() string
	Kind() string
	Name() string
	Namespace() string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL