apply

Documentation

Index

• Constants
• Variables
• type Apply
  • func New(discovery discovery.DiscoveryInterface, cf ClientFactory, ...) Apply
  • func NewForConfig(cfg *rest.Config) (Apply, error)
• type ClientFactory
  • func NewClientFactory(config *rest.Config) ClientFactory
• type InformerGetter
• type Patcher
• type Reconciler

Constants

const (
	LabelID        = "objectset.rio.cattle.io/id"
	LabelGVK       = "objectset.rio.cattle.io/owner-gvk"
	LabelName      = "objectset.rio.cattle.io/owner-name"
	LabelNamespace = "objectset.rio.cattle.io/owner-namespace"
	LabelHash      = "objectset.rio.cattle.io/hash"
)

const (
	LabelApplied = "objectset.rio.cattle.io/applied"
)

Variables

var (
	ErrReplace      = errors.New("replace object with changes")
	ReplaceOnChange = func(name string, o runtime.Object, patchType types2.PatchType, data []byte, subresources ...string) (runtime.Object, error) {
		return nil, ErrReplace
	}
)

Types

type Apply

type Apply interface {
	Apply(set *objectset.ObjectSet) error
	ApplyObjects(objs ...runtime.Object) error
	WithCacheTypes(igs ...InformerGetter) Apply
	WithSetID(id string) Apply
	WithOwner(obj runtime.Object) Apply
	WithInjector(injs ...injectors.ConfigInjector) Apply
	WithInjectorName(injs ...string) Apply
	WithPatcher(gvk schema.GroupVersionKind, patchers Patcher) Apply
	WithReconciler(gvk schema.GroupVersionKind, reconciler Reconciler) Apply
	WithStrictCaching() Apply
	WithDynamicLookup() Apply
	WithRestrictClusterScoped() Apply
	WithDefaultNamespace(ns string) Apply
	WithListerNamespace(ns string) Apply
	WithRateLimiting(ratelimitingQps float32) Apply
	WithNoDelete() Apply
	WithGVK(gvks ...schema.GroupVersionKind) Apply
	WithSetOwnerReference(controller, block bool) Apply
}

func New

func New(discovery discovery.DiscoveryInterface, cf ClientFactory, igs ...InformerGetter) Apply

func NewForConfig

func NewForConfig(cfg *rest.Config) (Apply, error)

type ClientFactory

type ClientFactory func(gvr schema.GroupVersionResource) (dynamic.NamespaceableResourceInterface, error)

func NewClientFactory

func NewClientFactory(config *rest.Config) ClientFactory

type InformerGetter

type InformerGetter interface {
	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind
}

type Patcher

type Patcher func(namespace, name string, pt types.PatchType, data []byte) (runtime.Object, error)

type Reconciler

type Reconciler func(oldObj runtime.Object, newObj runtime.Object) (bool, error)

return false if the Reconciler did not handler this object