schemacontroller

Documentation

Overview

DataInfra Pinot Control Plane (C) 2023 - 2024 DataInfra.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• func Create(e event.CreateEvent, log logr.Logger) bool
• func Update(e event.UpdateEvent, log logr.Logger) bool
• type GenericPredicates
  • func (GenericPredicates) Create(e event.CreateEvent) bool
  • func (GenericPredicates) Update(e event.UpdateEvent) bool
• type PinotSchemaReconciler
  • func NewPinotSchemaReconciler(mgr ctrl.Manager) *PinotSchemaReconciler
  • func (r *PinotSchemaReconciler) CreateOrUpdate(schema *v1beta1.PinotSchema, svcName string, build builder.Builder, ...) (controllerutil.OperationResult, error)
  • func (r *PinotSchemaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PinotSchemaReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	PinotSchemaControllerCreateSuccess      = "PinotSchemaControllerCreateSuccess"
	PinotSchemaControllerCreateFail         = "PinotSchemaControllerCreateFail"
	PinotSchemaControllerGetSuccess         = "PinotSchemaControllerGetSuccess"
	PinotSchemaControllerGetFail            = "PinotSchemaControllerGetFail"
	PinotSchemaControllerUpdateSuccess      = "PinotSchemaControllerUpdateSuccess"
	PinotSchemaControllerUpdateFail         = "PinotSchemaControllerUpdateFail"
	PinotSchemaControllerDeleteSuccess      = "PinotSchemaControllerDeleteSuccess"
	PinotSchemaControllerDeleteFail         = "PinotSchemaControllerDeleteFail"
	PinotSchemaControllerPatchStatusSuccess = "PinotSchemaControllerPatchStatusSuccess"
	PinotSchemaControllerPatchStatusFail    = "PinotSchemaControllerPatchStatusFail"
	PinotSchemaControllerFinalizer          = "pinotschema.datainfra.io/finalizer"
)

const (
	ControlPlaneUserName = "CONTROL_PLANE_USERNAME"
	ControlPlanePassword = "CONTROL_PLANE_PASSWORD"
)

const (
	PinotControllerPort = "9000"
)

Functions

func Create

func Create(e event.CreateEvent, log logr.Logger) bool

func Update

func Update(e event.UpdateEvent, log logr.Logger) bool

Types

type GenericPredicates

type GenericPredicates struct {
	predicate.GenerationChangedPredicate
}

All methods to implement GenericPredicates type GenericPredicates to be passed to manager

func (GenericPredicates) Create

func (GenericPredicates) Create(e event.CreateEvent) bool

create() to filter create events

func (GenericPredicates) Update

func (GenericPredicates) Update(e event.UpdateEvent) bool

update() to filter update events

type PinotSchemaReconciler

type PinotSchemaReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// reconcile time duration, defaults to 10s
	ReconcileWait time.Duration
	Recorder      record.EventRecorder
}

PinotSchemaReconciler reconciles a PinotSchema object

func NewPinotSchemaReconciler

func NewPinotSchemaReconciler(mgr ctrl.Manager) *PinotSchemaReconciler

func (*PinotSchemaReconciler) CreateOrUpdate

func (r *PinotSchemaReconciler) CreateOrUpdate(
	schema *v1beta1.PinotSchema,
	svcName string,
	build builder.Builder,
	auth internalHTTP.Auth,
) (controllerutil.OperationResult, error)

Get Schema if does not exist create if exists check for update

func (*PinotSchemaReconciler) Reconcile

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

+kubebuilder:rbac:groups=datainfra.io,resources=pinotschemas,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=datainfra.io,resources=pinotschemas/status,verbs=get;update;patch +kubebuilder:rbac:groups=datainfra.io,resources=pinotschemas/finalizers,verbs=update +kubebuilder:rbac:groups="",resources=secret,verbs=get

func (*PinotSchemaReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.