controllers

package
v0.31.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 12, 2026 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GuessClusterDomain 

func GuessClusterDomain(ctx context.Context) (string, error)

Types

type BaseReconciler 

type BaseReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder

	WatchOperatorInstance string
	ClusterDomain         string
}

func (*BaseReconciler) ShouldIgnoreResource 

func (r *BaseReconciler) ShouldIgnoreResource(ctx context.Context, object client.Object) bool

type ChytReconciler 

type ChytReconciler struct {
	BaseReconciler
}

ChytReconciler reconciles a Chyt object

func (*ChytReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Chyt object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile

func (*ChytReconciler) SetupWithManager 

func (r *ChytReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*ChytReconciler) Sync 

func (r *ChytReconciler) Sync(ctx context.Context, resource *ytv1.Chyt, ytsaurus *ytv1.Ytsaurus) (ctrl.Result, error)

type ComponentManager 

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

func NewComponentManager 

func NewComponentManager(
	ctx context.Context,
	ytsaurus *apiProxy.Ytsaurus,
	clusterDomain string,
) (*ComponentManager, error)

func (*ComponentManager) FetchStatus 

func (cm *ComponentManager) FetchStatus(ctx context.Context) error

func (*ComponentManager) Sync 

func (cm *ComponentManager) Sync(ctx context.Context) (ctrl.Result, error)

type ComponentManagerStatus 

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

type OffshoreDataGatewaysReconciler 

type OffshoreDataGatewaysReconciler struct {
	BaseReconciler
}

OffshoreDataGatewaysReconciler reconciles a OffshoreDataGateways object

func (*OffshoreDataGatewaysReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the OffshoreDataGateways object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile

func (*OffshoreDataGatewaysReconciler) SetupWithManager 

func (r *OffshoreDataGatewaysReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*OffshoreDataGatewaysReconciler) Sync 

func (r *OffshoreDataGatewaysReconciler) Sync(
	ctx context.Context,
	resource *ytv1.OffshoreDataGateways,
	remoteYtsaurus *ytv1.RemoteYtsaurus,
) (ctrl.Result, error)

type RemoteDataNodesReconciler 

type RemoteDataNodesReconciler struct {
	BaseReconciler
}

RemoteDataNodesReconciler reconciles a RemoteDataNodes object

func (*RemoteDataNodesReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the RemoteDataNodes object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile

func (*RemoteDataNodesReconciler) SetupWithManager 

func (r *RemoteDataNodesReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*RemoteDataNodesReconciler) Sync 

func (r *RemoteDataNodesReconciler) Sync(
	ctx context.Context,
	resource *ytv1.RemoteDataNodes,
	remoteYtsaurus *ytv1.RemoteYtsaurus,
) (ctrl.Result, error)

type RemoteExecNodesReconciler 

type RemoteExecNodesReconciler struct {
	BaseReconciler
}

RemoteExecNodesReconciler reconciles a RemoteExecNodes object

func (*RemoteExecNodesReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the RemoteExecNodes object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile

func (*RemoteExecNodesReconciler) SetupWithManager 

func (r *RemoteExecNodesReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*RemoteExecNodesReconciler) Sync 

func (r *RemoteExecNodesReconciler) Sync(
	ctx context.Context,
	resource *ytv1.RemoteExecNodes,
	remoteYtsaurus *ytv1.RemoteYtsaurus,
) (ctrl.Result, error)

type RemoteTabletNodesReconciler 

type RemoteTabletNodesReconciler struct {
	BaseReconciler
}

RemoteTabletNodesReconciler reconciles a RemoteTabletNodes object

func (*RemoteTabletNodesReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the RemoteTabletNodes object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile

func (*RemoteTabletNodesReconciler) SetupWithManager 

func (r *RemoteTabletNodesReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*RemoteTabletNodesReconciler) Sync 

func (r *RemoteTabletNodesReconciler) Sync(
	ctx context.Context,
	resource *ytv1.RemoteTabletNodes,
	remoteYtsaurus *ytv1.RemoteYtsaurus,
) (ctrl.Result, error)

type SpytReconciler 

type SpytReconciler struct {
	BaseReconciler
}

SpytReconciler reconciles a Spyt object

func (*SpytReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Spyt object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*SpytReconciler) SetupWithManager 

func (r *SpytReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*SpytReconciler) Sync 

func (r *SpytReconciler) Sync(ctx context.Context, resource *ytv1.Spyt, ytsaurus *ytv1.Ytsaurus) (ctrl.Result, error)

type YtsaurusReconciler 

type YtsaurusReconciler struct {
	BaseReconciler
}

YtsaurusReconciler reconciles a Ytsaurus object

func (*YtsaurusReconciler) Reconcile 

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

+kubebuilder:rbac:groups=cluster.ytsaurus.tech,resources=ytsaurus,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=cluster.ytsaurus.tech,resources=ytsaurus/status,verbs=get;update;patch +kubebuilder:rbac:groups=cluster.ytsaurus.tech,resources=ytsaurus/finalizers,verbs=update +kubebuilder:rbac:groups=apps,resources=statefulset,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=apps,resources=statefulset/status,verbs=get +kubebuilder:rbac:groups=core,resources=pod,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=core,resources=pod/status,verbs=get +kubebuilder:rbac:groups="",resources=configmaps,verbs=get;list;watch

func (*YtsaurusReconciler) SetupWithManager 

func (r *YtsaurusReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*YtsaurusReconciler) Sync 

func (r *YtsaurusReconciler) Sync(ctx context.Context, resource *ytv1.Ytsaurus) (ctrl.Result, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.