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

	// ClearResources clear all resource about sub-component.
	// todo(yandongxiao): rename to ClearCluster
	ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error

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

	// UpdateClusterStatus only update the component status in src.
	// todo(yandongxiao): better to rename it, because it does not send update request 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(ctx context.Context, warehouse *srapi.StarRocksWarehouse) error
}