k8s

package
v0.2.0-beta.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetClusterIDFromClusterAnnotations

func GetClusterIDFromClusterAnnotations(cluster *v1beta2.Cluster) (int32, error)

GetClusterIDFromClusterAnnotations returns the cluster ID from the given cluster annotations

func GetClusterLabelsForDatabase

func GetClusterLabelsForDatabase(database *v1beta2.Database) map[string]string

GetClusterLabelsForDatabase returns the labels for the clusters in the given database

func GetClusterName

func GetClusterName(database *v1beta2.Database, cluster int) string

GetClusterName returns the cluster name for the given cluster

func GetClusterNamespacedName

func GetClusterNamespacedName(database *v1beta2.Database, cluster int) types.NamespacedName

GetClusterNamespacedName returns the NamespacedName for the given cluster

func GetControllerName

func GetControllerName() string

GetControllerName gets the name of the current controller from the environment

func GetControllerNamespace

func GetControllerNamespace() string

GetControllerNamespace gets the controller's namespace from the environment

func GetDatabaseNamespace

func GetDatabaseNamespace(id *api.DatabaseId) string

GetDatabaseNamespace returns the Database namespace for the given database ID

func GetPartitionLabelsForCluster

func GetPartitionLabelsForCluster(cluster *v1beta2.Cluster) map[string]string

GetPartitionLabelsForCluster returns the labels for the partitions in the given cluster

func GetPartitionLabelsForDatabase

func GetPartitionLabelsForDatabase(database *v1beta2.Database) map[string]string

GetPartitionLabelsForDatabase returns the labels for the partitions in the given database

func GetPartitionName

func GetPartitionName(cluster *v1beta2.Cluster, partition int32) string

GetPartitionName returns the partition name for the given cluster

func GetPartitionNamespacedName

func GetPartitionNamespacedName(cluster *v1beta2.Cluster, partition int32) types.NamespacedName

GetPartitionNamespacedName returns the NamespacedName for the given partition

func GetQualifiedControllerName

func GetQualifiedControllerName() string

GetQualifiedControllerName returns the qualified controller name

func NewCluster

func NewCluster(database *v1beta2.Database, cluster int) *v1beta2.Cluster

NewCluster returns the configuration for the given cluster

func NewDatabaseProto

func NewDatabaseProto(database *v1beta2.Database) *api.Database

NewDatabaseProto returns a Database proto message for the given Database

func NewPartition

func NewPartition(cluster *v1beta2.Cluster, partition int32) *v1beta2.Partition

NewPartition returns the configuration for the given partition

func NewPartitionProto

func NewPartitionProto(p *v1beta2.Partition) (*api.Partition, error)

NewPartitionProto returns the partition proto message for the given Partition

Types

This section is empty.

Jump to

Keyboard shortcuts

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