k8s

package

v0.3.0-beta.2 Latest Latest Go to latest Published: Apr 25, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func GetControllerName() string

GetControllerName gets the name of the current controller from the environment

func GetControllerNamespace() string

GetControllerNamespace gets the controller's namespace from the environment

func GetDatabaseNamespace(id *api.DatabaseId) string

GetDatabaseNamespace returns the Database namespace for the given database ID

func GetPartitionIDFromPartitionAnnotations(partition *v1beta3.Partition) (int32, error)

GetPartitionIDFromPartitionAnnotations returns the partition ID from the given partition annotations

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

GetPartitionLabelsForDatabase returns the labels for the partitions in the given database

func GetPartitionName(database *v1beta3.Database, partition int) string

GetPartitionName returns the partition name for the given partition

func GetPartitionNamespacedName(database *v1beta3.Database, partition int) types.NamespacedName

GetPartitionNamespacedName returns the NamespacedName for the given partition

func GetPartitionServiceName(database *v1beta3.Database, partition int) string

GetPartitionServiceName returns the service name for the given partition

func GetQualifiedControllerName() string

GetQualifiedControllerName returns the qualified controller name

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

NewDatabaseProto returns a Database proto message for the given Database

func NewPartition(database *v1beta3.Database, partition int) *v1beta3.Partition

NewPartition returns the configuration for the given partition

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

NewPartitionProto returns the partition proto message for the given Partition

This section is empty.