controller

package

Go to main page

Versions in this module

v0

v0.0.6

Jun 6, 2024

v0.0.5

May 13, 2024

v0.0.4

Mar 28, 2024

Changes in this version

type ControllerBuilder

+ func NewControllerFor(r *pb.Resource) *ControllerBuilder

+ func (c *ControllerBuilder) Create(reconciler string, grpcClient *grpc.RemoteWorkProcessorGrpcClient, ...) error

+ func (c *ControllerBuilder) WithSelector(selector *selector.Selector) *ControllerBuilder

+ type Manager struct

+ func (m *Manager) CreateControllersFor(resources map[string]*pb.Resource, isEnabled func() bool) error

+ func (m *Manager) Start(ctx context.Context) error

type ManagerBuilder

+ func NewManagerBuilder() *ManagerBuilder

+ func (b *ManagerBuilder) BuildDynamicClient(config *rest.Config) *ManagerBuilder

+ func (b *ManagerBuilder) BuildInternalManager(config *rest.Config, scheme *runtime.Scheme) *ManagerBuilder

+ func (b *ManagerBuilder) SetGrpcClient(client *grpc.RemoteWorkProcessorGrpcClient) *ManagerBuilder

type ManagerEngine

+ func (e *ManagerEngine) IsRunning() bool

+ func (e *ManagerEngine) SetWatchConfiguration(wc *pb.UpdateConfigRequestMessage)

+ func (e *ManagerEngine) Stop()

+ func (e *ManagerEngine) WatchResources(ctx context.Context, isEnabled func() bool) error

v0.0.3

Oct 20, 2023

v0.0.2

Oct 18, 2023

v0.0.1

Jun 5, 2023

Changes in this version

type ControllerBuilder

+ func (cb *ControllerBuilder) WithReconcilicationPeriodInMinutes(p int32) *ControllerBuilder

v0.0.0

May 21, 2023

Changes in this version

+ const FINALIZER

+ const OPERATOR_ID_ENV_VAR

+ type Controller struct

+ type ControllerBuilder struct

+ func CreateControllerBuilder() *ControllerBuilder

+ func (cb *ControllerBuilder) Build(ctx context.Context, reconciler string) (Controller, error)

+ func (cb *ControllerBuilder) For(r *pb.Resource) *ControllerBuilder

+ func (cb *ControllerBuilder) ManagedBy(m *ControllerManager) *ControllerBuilder

+ type ControllerManager struct

+ func (m *ControllerManager) CreateControllers(ctx context.Context) error

+ func (m *ControllerManager) GetClient() client.Client

+ func (m *ControllerManager) GetScheme() *runtime.Scheme

+ type ControllerManagerBuilder struct

+ func CreateManagerBuilder() *ControllerManagerBuilder

+ func (cm *ControllerManagerBuilder) Build() ControllerManager

+ func (cm *ControllerManagerBuilder) WithConfig(config *rest.Config) *ControllerManagerBuilder

+ func (cm *ControllerManagerBuilder) WithOptions(scheme *runtime.Scheme) *ControllerManagerBuilder

+ func (cm *ControllerManagerBuilder) WithWatchConfiguration(wc *pb.UpdateConfigRequestMessage) *ControllerManagerBuilder

+ func (cm *ControllerManagerBuilder) WithoutLeaderElection() *ControllerManagerBuilder

+ type ManagerBuilder interface

+ Build func() ControllerManager

+ WithConfig func(config *rest.Config) *ControllerManagerBuilder

+ WithOptions func(scheme *runtime.Scheme, enableLeaderElection bool) *ControllerManagerBuilder

+ WithWatchConfiguration func(wc *pb.UpdateConfigRequestMessage) *ControllerManagerBuilder

+ WithoutLeaderElection func() *ControllerManagerBuilder

+ type ManagerEngine struct

+ func CreateManagerEngine(scheme *runtime.Scheme, config *rest.Config) *ManagerEngine

+ func (e *ManagerEngine) ManagerStartedAtLeastOnce() bool

+ func (e *ManagerEngine) StartManager() error

+ func (e *ManagerEngine) StopManager()

+ func (e *ManagerEngine) WithContext()

+ func (e *ManagerEngine) WithWatchConfiguration(wc *pb.UpdateConfigRequestMessage)

+ type ReconciliationEvent struct

+ type ResourceControllerBuilder interface

+ Build func() Controller

+ For func(r *pb.Resource) *ControllerBuilder

+ ManagedBy func(m *ControllerManager) *ControllerBuilder

+ type WatchConfigReconciler struct

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

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