operatorbootstrap

Documentation

Index

• Variables
• func Cancelled() bool
• func CustomSignalsHandler(additionalActionBeforeCancel func()) context.Context
• func MustSetupController(err error)
• type Bootstrapper
  • func NewBootstrapper(ctx context.Context, operatorCfg operatorconfig.OperatorConfig, ...) *Bootstrapper
  • func (b *Bootstrapper) Context() context.Context
  • func (b *Bootstrapper) GetMgr() manager.Manager
  • func (b *Bootstrapper) Run()
  • func (b *Bootstrapper) WithControllers(controllers ...KubernetesOperator) *Bootstrapper
• type KubernetesOperator

Variables

var (
	AddPodIndexersToManager operatorbootstrapinternal.ManagerFunc = func(mgr manager.Manager) {
		if err := mgr.GetFieldIndexer().IndexField(context.Background(), &v1.Pod{}, "spec.nodeName", func(o client.Object) []string {
			return []string{o.(*v1.Pod).Spec.NodeName}
		}); err != nil {
			panic(fmt.Sprintf("Failed to setup pod indexer, %s", err))
		}
	}
)

Functions

func Cancelled

func Cancelled() bool

func CustomSignalsHandler

func CustomSignalsHandler(additionalActionBeforeCancel func()) context.Context

func MustSetupController

func MustSetupController(err error)

Types

type Bootstrapper

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

func NewBootstrapper

func NewBootstrapper(ctx context.Context, operatorCfg operatorconfig.OperatorConfig, newOpts func() ctrl.Options, mgrFunc operatorbootstrapinternal.ManagerFunc) *Bootstrapper

func (*Bootstrapper) Context

func (b *Bootstrapper) Context() context.Context

func (*Bootstrapper) GetMgr

func (b *Bootstrapper) GetMgr() manager.Manager

func (*Bootstrapper) Run

func (b *Bootstrapper) Run()

func (*Bootstrapper) WithControllers

func (b *Bootstrapper) WithControllers(controllers ...KubernetesOperator) *Bootstrapper

type KubernetesOperator

type KubernetesOperator interface {
	reconcile.Reconciler
	SetupWithManager(mgr ctrl.Manager) error
}