The highest tagged major version is v3.

controllerutils

package

v0.6.0 Latest Latest Go to latest Published: Dec 29, 2022 License: MIT Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/formancehq/operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CreateConfigMapFromDir(ctx context.Context, name types.NamespacedName, client client.Client, ...) (controllerutil.OperationResult, error)
func CreateOrUpdateWithController[T client.Object](ctx context.Context, client client.Client, scheme *runtime.Scheme, ...) (T, controllerutil.OperationResult, error)
func DefaultLiveness() *corev1.Probe
func DefineOwner(ctx context.Context, client client.Client, scheme *runtime.Scheme, ...) error
func GetImage(component, version string) string
func ImagePullPolicy(o interface{ ... }) corev1.PullPolicy
func IsDeleted(meta client.Object) bool
func OwnerReference(o client.Object) metav1.OwnerReference
func Requeue(after ...time.Duration) *controllerruntime.Result
func SetSecretError(object apisv1beta2.Object, msg ...string)
func SetSecretReady(object apisv1beta2.Object, msg ...string)
func SinglePort(name string, port int32) []v1.ContainerPort
type Finalizer
- func New(name string) *Finalizer
- func (f *Finalizer) Add(ctx context.Context, client client.Client, object client.Object) error
- func (f *Finalizer) AssertIsInstalled(ctx context.Context, client client.Client, ob client.Object) error
- func (f *Finalizer) Handle(ctx context.Context, client client.Client, ob client.Object, fn func() error) (bool, error)
- func (f *Finalizer) IsPresent(ob client.Object) bool
- func (f *Finalizer) Remove(ctx context.Context, client client.Client, object client.Object) error
type Mutator
type Reconciler
- func NewReconciler[T apisv1beta2.Object](client client.Client, scheme *runtime.Scheme, mutator Mutator[T]) *Reconciler[T]
- func (r *Reconciler[T]) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *Reconciler[T]) SetupWithManager(mgr ctrl.Manager) error

Constants ¶

View Source

const (
	ConditionTypeSecretReady = "SecretReady"
)

Variables ¶

This section is empty.

Functions ¶

func CreateConfigMapFromDir ¶

func CreateConfigMapFromDir(ctx context.Context, name types.NamespacedName, client client.Client, scheme *runtime.Scheme,
	owner client.Object, fs fs.FS, rootDir string) (controllerutil.OperationResult, error)

func CreateOrUpdateWithController ¶

func CreateOrUpdateWithController[T client.Object](ctx context.Context, client client.Client, scheme *runtime.Scheme,
	key types.NamespacedName, owner client.Object, mutate func(t T) error) (T, controllerutil.OperationResult, error)

func DefaultLiveness ¶

func DefaultLiveness() *corev1.Probe

func DefineOwner ¶

func DefineOwner(ctx context.Context, client client.Client, scheme *runtime.Scheme, ob client.Object, ownerKey types.NamespacedName, ownerType client.Object) error

func GetImage ¶

func GetImage(component, version string) string

func ImagePullPolicy ¶

func ImagePullPolicy(o interface {
	GetVersion() string
}) corev1.PullPolicy

func IsDeleted ¶

func IsDeleted(meta client.Object) bool

func OwnerReference ¶

func OwnerReference(o client.Object) metav1.OwnerReference

func Requeue ¶

func Requeue(after ...time.Duration) *controllerruntime.Result

func SetSecretError ¶

func SetSecretError(object apisv1beta2.Object, msg ...string)

func SetSecretReady ¶

func SetSecretReady(object apisv1beta2.Object, msg ...string)

func SinglePort ¶

func SinglePort(name string, port int32) []v1.ContainerPort

Types ¶

type Finalizer ¶

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

func New ¶

func New(name string) *Finalizer

func (*Finalizer) Add ¶

func (f *Finalizer) Add(ctx context.Context, client client.Client, object client.Object) error

func (*Finalizer) AssertIsInstalled ¶

func (f *Finalizer) AssertIsInstalled(ctx context.Context, client client.Client, ob client.Object) error

func (*Finalizer) Handle ¶

func (f *Finalizer) Handle(ctx context.Context, client client.Client, ob client.Object, fn func() error) (bool, error)

func (*Finalizer) IsPresent ¶

func (f *Finalizer) IsPresent(ob client.Object) bool

func (*Finalizer) Remove ¶

func (f *Finalizer) Remove(ctx context.Context, client client.Client, object client.Object) error

type Mutator ¶

type Mutator[T apisv1beta2.Object] interface {
	SetupWithBuilder(mgr ctrl.Manager, builder *ctrl.Builder) error
	Mutate(ctx context.Context, t T) (*ctrl.Result, error)
}

type Reconciler ¶

type Reconciler[T apisv1beta2.Object] struct {
	client.Client
	Scheme  *runtime.Scheme
	Mutator Mutator[T]
}

Reconciler reconciles a Stack object

func NewReconciler ¶

func NewReconciler[T apisv1beta2.Object](client client.Client, scheme *runtime.Scheme, mutator Mutator[T]) *Reconciler[T]

func (*Reconciler[T]) Reconcile ¶

func (r *Reconciler[T]) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*Reconciler[T]) SetupWithManager ¶

func (r *Reconciler[T]) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Source Files ¶

View all Source files

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