controller

Documentation

Index

• Constants
• func ConfigMapOrSecretTrigger(ctx context.Context, cli client.Client) handler.EventHandler
• func PluginUnhealthyTrigger(ctx context.Context, cli client.Client) handler.EventHandler
• func Run(ctx context.Context, options *Options, cachedir string) error
• func Setup(ctx context.Context, mgr ctrl.Manager, options *bundle.Options) error
• type DependencyError
  • func (e DependencyError) Error() string
• type Options
  • func NewDefaultOptions() *Options
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) Sync(ctx context.Context, bundle *pluginsv1beta1.Plugin) error

Constants

const (
	PluginsControllerConcurrency = 3
	FinalizerName                = "plugins.kubegems.io/finalizer"
)

Functions

func ConfigMapOrSecretTrigger

func ConfigMapOrSecretTrigger(ctx context.Context, cli client.Client) handler.EventHandler

func PluginUnhealthyTrigger

func PluginUnhealthyTrigger(ctx context.Context, cli client.Client) handler.EventHandler

func Run

func Run(ctx context.Context, options *Options, cachedir string) error

func Setup

func Setup(ctx context.Context, mgr ctrl.Manager, options *bundle.Options) error

Types

type DependencyError

type DependencyError struct {
	Reason string
	Object corev1.ObjectReference
}

func (DependencyError) Error

func (e DependencyError) Error() string

type Options

type Options struct {
	MetricsAddr          string `json:"metricsAddr,omitempty" description:"The address the metric endpoint binds to."`
	EnableLeaderElection bool   `json:"enableLeaderElection,omitempty" description:"Enable leader election for controller manager."`
	ProbeAddr            string `json:"probeAddr,omitempty" description:"The address the probe endpoint binds to."`
}

func NewDefaultOptions

func NewDefaultOptions() *Options

type Reconciler

type Reconciler struct {
	client.Client
	Applier *bundle.BundleApplier
}

func (*Reconciler) Reconcile

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

func (*Reconciler) Sync

func (r *Reconciler) Sync(ctx context.Context, bundle *pluginsv1beta1.Plugin) error

Sync