labeller

package

v0.30.0 Latest Latest Go to latest Published: Feb 2, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ytsaurus/ytsaurus-k8s-operator

Links

Open Source Insights

Documentation ¶

Index ¶

type Labeller

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Labeller ¶

type Labeller struct {
	Namespace string

	// Name of YTsaurus cluster.
	ClusterName string

	// Name of resource which defines this component.
	ResourceName string

	ComponentType consts.ComponentType

	// An optional name identifying a group of instances of the type above.
	// Role for proxies, instance group name for nodes, may be empty.
	InstanceGroup string

	// K8s cluster domain, usually "cluster.local".
	ClusterDomain string

	Annotations map[string]string

	// Do not include resource name into component name.
	UseShortNames bool
}

Labeller defines component names, labels and addresses.

func (*Labeller) ForComponent ¶

func (l *Labeller) ForComponent(component consts.ComponentType, instanceGroup string) *Labeller

func (*Labeller) GetAnnotations ¶

func (l *Labeller) GetAnnotations() map[string]string

func (*Labeller) GetBalancerServiceAddress ¶

func (l *Labeller) GetBalancerServiceAddress() string

func (*Labeller) GetBalancerServiceName ¶

func (l *Labeller) GetBalancerServiceName() string

func (*Labeller) GetClusterDomain ¶

func (l *Labeller) GetClusterDomain() string

func (*Labeller) GetClusterName ¶

func (l *Labeller) GetClusterName() string

func (*Labeller) GetComponentLabel ¶

func (l *Labeller) GetComponentLabel() string

GetComponentLabel Returns lower case hyphenated component type without name part.

func (*Labeller) GetComponentShortName ¶

func (l *Labeller) GetComponentShortName() string

func (*Labeller) GetComponentTypeLabelValue ¶

func (l *Labeller) GetComponentTypeLabelValue(isInitJob bool) string

func (*Labeller) GetCypressPatchConfigMapName ¶

func (l *Labeller) GetCypressPatchConfigMapName() string

func (*Labeller) GetCypressPatchFileName ¶

func (l *Labeller) GetCypressPatchFileName(name string) string

func (*Labeller) GetFullComponentLabel ¶

func (l *Labeller) GetFullComponentLabel() string

GetFullComponentLabel Returns lower case hyphenated component type with name part.

func (*Labeller) GetFullComponentName ¶

func (l *Labeller) GetFullComponentName() string

GetFullComponentName Returns CamelCase component type with instance group.

func (*Labeller) GetHeadlessServiceAddress ¶

func (l *Labeller) GetHeadlessServiceAddress() string

func (*Labeller) GetHeadlessServiceName ¶

func (l *Labeller) GetHeadlessServiceName() string

func (*Labeller) GetInitJobCompletedCondition ¶

func (l *Labeller) GetInitJobCompletedCondition(name string) string

func (*Labeller) GetInitJobConfigMapName ¶

func (l *Labeller) GetInitJobConfigMapName(name string) string

func (*Labeller) GetInitJobName ¶

func (l *Labeller) GetInitJobName(name string) string

func (*Labeller) GetInitJobObjectMeta ¶

func (l *Labeller) GetInitJobObjectMeta() metav1.ObjectMeta

func (*Labeller) GetInstanceAddressPort ¶

func (l *Labeller) GetInstanceAddressPort(index, port int) string

func (*Labeller) GetInstanceAddressWildcard ¶

func (l *Labeller) GetInstanceAddressWildcard() string

func (*Labeller) GetInstanceGroup ¶

func (l *Labeller) GetInstanceGroup() string

func (*Labeller) GetInstanceLabelValue ¶

func (l *Labeller) GetInstanceLabelValue(isInitJob bool) string

func (*Labeller) GetListOptions ¶

func (l *Labeller) GetListOptions() []client.ListOption

func (*Labeller) GetMainConfigMapName ¶

func (l *Labeller) GetMainConfigMapName() string

func (*Labeller) GetMetaLabelMap ¶

func (l *Labeller) GetMetaLabelMap(isInitJob bool) map[string]string

func (*Labeller) GetMonitoringMetaLabelMap ¶

func (l *Labeller) GetMonitoringMetaLabelMap() map[string]string

func (*Labeller) GetMonitoringServiceName ¶

func (l *Labeller) GetMonitoringServiceName() string

func (*Labeller) GetNamespace ¶

func (l *Labeller) GetNamespace() string

func (*Labeller) GetObjectMeta ¶

func (l *Labeller) GetObjectMeta(name string) metav1.ObjectMeta

func (*Labeller) GetPartOfLabelValue ¶

func (l *Labeller) GetPartOfLabelValue() string

func (*Labeller) GetPodsRemovedCondition ¶

func (l *Labeller) GetPodsRemovedCondition() string

func (*Labeller) GetPodsRemovingStartedCondition ¶

func (l *Labeller) GetPodsRemovingStartedCondition() string

func (*Labeller) GetPodsUpdatedCondition ¶

func (l *Labeller) GetPodsUpdatedCondition() string

func (*Labeller) GetPreChecksRunningCondition ¶

func (l *Labeller) GetPreChecksRunningCondition() string

func (*Labeller) GetReadyCondition ¶

func (l *Labeller) GetReadyCondition() string

func (*Labeller) GetScalingDownCondition ¶

func (l *Labeller) GetScalingDownCondition() string

func (*Labeller) GetScalingUpCondition ¶

func (l *Labeller) GetScalingUpCondition() string

func (*Labeller) GetSecretName ¶

func (l *Labeller) GetSecretName() string

func (*Labeller) GetSelectorLabelMap ¶

func (l *Labeller) GetSelectorLabelMap() map[string]string

func (*Labeller) GetServerStatefulSetName ¶

func (l *Labeller) GetServerStatefulSetName() string

func (*Labeller) GetSidecarConfigMapName ¶

func (l *Labeller) GetSidecarConfigMapName(name string) string

func (*Labeller) GetWaitingOnDeleteUpdateCondition ¶

func (l *Labeller) GetWaitingOnDeleteUpdateCondition() string

Source Files ¶

View all Source files

labeller.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL