subcontrollers

Documentation

Overview

+k8s:deepcopy-gen=package +groupName=starrocks.com

Index

• Constants
• func UpdateStatus(componentStatus *srapi.StarRocksComponentStatus, k8sClient client.Client, ...) error
• type ClusterSubController
• type GetEventRecorderForFunc
• type LoadType
• type WarehouseSubController

Constants

const (
	DeploymentLoadType  = "Deployment"
	StatefulSetLoadType = "StatefulSet"
)

Functions

func UpdateStatus

func UpdateStatus(componentStatus *srapi.StarRocksComponentStatus, k8sClient client.Client,
	namespace string, name string, podLabels map[string]string, loadType LoadType) error

Types

type ClusterSubController

type ClusterSubController interface {
	// SyncCluster reconcile for sub controller. bool represent the component have updated.
	SyncCluster(ctx context.Context, src *srapi.StarRocksCluster) error

	// ClearCluster clear all subresources.
	ClearCluster(ctx context.Context, src *srapi.StarRocksCluster) error

	// GetControllerName return the controller name, beController, feController,cnController for log.
	GetControllerName() string

	// UpdateClusterStatus only updates the status locally, but not update it to k8s
	UpdateClusterStatus(ctx context.Context, src *srapi.StarRocksCluster) error
}

type GetEventRecorderForFunc

type GetEventRecorderForFunc func(name string) record.EventRecorder

type LoadType

type LoadType string

type WarehouseSubController

type WarehouseSubController interface {
	// ClearWarehouse will clear all resource about warehouse.
	ClearWarehouse(ctx context.Context, namespace string, name string) error

	SyncWarehouse(ctx context.Context, src *srapi.StarRocksWarehouse) error

	GetControllerName() string

	// UpdateWarehouseStatus only updates the status locally, but not update it to k8s
	UpdateWarehouseStatus(ctx context.Context, warehouse *srapi.StarRocksWarehouse) error
}