pinotcontroller

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 NodeTypeNodeSpec
• type PinotReconciler
  • func NewPinotReconciler(mgr ctrl.Manager) *PinotReconciler
  • func (r *PinotReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PinotReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	MinionConfigMapVolumeMountPath     = "/var/pinot/minion/config"
	ServerConfigMapVolumeMountPath     = "/var/pinot/server/config"
	ControllerConfigMapVolumeMountPath = "/var/pinot/controller/config"
	BrokerConfigMapVolumeMountPath     = "/var/pinot/broker/config"
	MinionConfName                     = "pinot-minion.conf"
	ServerConfName                     = "pinot-server.conf"
	ControllerConfName                 = "pinot-controller.conf"
	BrokerConfName                     = "pinot-broker.conf"
	StartBroker                        = "StartBroker"
	StartController                    = "StartController"
	StartServer                        = "StartServer"
	StartMinion                        = "StartMinion"
)

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.Funcs
}

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 NodeTypeNodeSpec

type NodeTypeNodeSpec struct {
	NodeType v1beta1.PinotNodeType
	NodeSpec v1beta1.NodeSpec
}

NodeType and nodeSpec makes it easier to iterate decisions around N nodespec each to a nodeType

type PinotReconciler

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

PinotReconciler reconciles a Pinot object

func NewPinotReconciler

func NewPinotReconciler(mgr ctrl.Manager) *PinotReconciler

func (*PinotReconciler) Reconcile

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

func (*PinotReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.