utils

package
v0.0.0-...-6ae417f Latest Latest
Warning

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

Go to latest
Published: Jan 11, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ANALYTICS      = "Analytics.tf.tungsten.io"
	QUERYENGINE    = "QueryEngine.tf.tungsten.io"
	ANALYTICSSNMP  = "AnalyticsSnmp.tf.tungsten.io"
	ANALYTICSALARM = "AnalyticsAlarm.tf.tungsten.io"
	CASSANDRA      = "Cassandra.tf.tungsten.io"
	ZOOKEEPER      = "Zookeeper.tf.tungsten.io"
	RABBITMQ       = "Rabbitmq.tf.tungsten.io"
	REDIS          = "Redis.tf.tungsten.io"
	CONFIG         = "Config.tf.tungsten.io"
	CONTROL        = "Control.tf.tungsten.io"
	WEBUI          = "Webui.tf.tungsten.io"
	VROUTER        = "Vrouter.tf.tungsten.io"
	KUBEMANAGER    = "Kubemanager.tf.tungsten.io"
	MANAGER        = "Manager.tf.tungsten.io"
	REPLICASET     = "ReplicaSet.apps"
	DEPLOYMENT     = "Deployment.apps"
)

const defines the Group constants.

Variables

This section is empty.

Functions

func AnalyticsActiveChange

func AnalyticsActiveChange() predicate.Funcs

AnalyticsActiveChange returns predicate function based on group kind.

func AnalyticsAlarmGroupKind

func AnalyticsAlarmGroupKind() schema.GroupKind

AnalyticsAlarmGroupKind returns group kind.

func AnalyticsGroupKind

func AnalyticsGroupKind() schema.GroupKind

AnalyticsGroupKind returns group kind.

func AnalyticsSnmpGroupKind

func AnalyticsSnmpGroupKind() schema.GroupKind

AnalyticsSnmpGroupKind returns group kind.

func CassandraActiveChange

func CassandraActiveChange() predicate.Funcs

CassandraActiveChange returns predicate function based on group kind.

func CassandraGroupKind

func CassandraGroupKind() schema.GroupKind

CassandraGroupKind returns group kind.

func CleanupContainers

func CleanupContainers(pod *corev1.PodSpec, spec []*v1alpha1.Container)

func ConfigActiveChange

func ConfigActiveChange() predicate.Funcs

ConfigActiveChange returns predicate function based on group kind.

func ConfigGroupKind

func ConfigGroupKind() schema.GroupKind

ConfigGroupKind returns group kind.

func ControlActiveChange

func ControlActiveChange() predicate.Funcs

ControlActiveChange returns predicate function based on group kind.

func ControlGroupKind

func ControlGroupKind() schema.GroupKind

ControlGroupKind returns group kind.

func DSStatusChange

func DSStatusChange(appGroupKind schema.GroupKind) predicate.Funcs

DSStatusChange monitors per application size change.

func DeploymentGroupKind

func DeploymentGroupKind() schema.GroupKind

DeploymentGroupKind returns group kind.

func DeploymentStatusChange

func DeploymentStatusChange(appGroupKind schema.GroupKind) predicate.Funcs

DeploymentStatusChange monitors per application size change.

func GetContainerFromList

func GetContainerFromList(containerName string, containerList []*v1alpha1.Container) *v1alpha1.Container

GetContainerFromList gets a container from a list of container

func KubemanagerGroupKind

func KubemanagerGroupKind() schema.GroupKind

KubemanagerGroupKind returns group kind.

func ManagerGroupKind

func ManagerGroupKind() schema.GroupKind

ManagerGroupKind returns group kind.

func MergeCommonConfiguration

func MergeCommonConfiguration(manager v1alpha1.ManagerConfiguration,
	instance v1alpha1.PodConfiguration) v1alpha1.PodConfiguration

MergeCommonConfiguration combines common configuration of manager and service.

func MergeUnstructuredCommonConfig

func MergeUnstructuredCommonConfig(
	commonConfig map[string]interface{},
	resourceConfig interface{}) interface{}

Get two unstructured object: manager's CommonConfiguration and resource specific CommonConfiguration from manager manifest. Set or replace fields in CommonConfig by valyes from specific config and return result structure

func PodIPChange

func PodIPChange(appLabel map[string]string) predicate.Funcs

PodIPChange returns predicate function based on group kind.

func PodPhaseChanges

func PodPhaseChanges(podLabels map[string]string) predicate.Funcs

PodPhaseChanges Check if some labeled pods switch to Running or from Running to another phase

func QueryEngineGroupKind

func QueryEngineGroupKind() schema.GroupKind

QueryEngineGroupKind returns group kind.

func RabbitmqActiveChange

func RabbitmqActiveChange() predicate.Funcs

RabbitmqActiveChange returns predicate function based on group kind.

func RabbitmqGroupKind

func RabbitmqGroupKind() schema.GroupKind

RabbitmqGroupKind returns group kind.

func RedisActiveChange

func RedisActiveChange() predicate.Funcs

RedisActiveChange returns predicate function based on group kind.

func RedisGroupKind

func RedisGroupKind() schema.GroupKind

RedisGroupKind returns group kind.

func RemoveIndex

func RemoveIndex(s []corev1.Container, index int) []corev1.Container

func ReplicaSetGroupKind

func ReplicaSetGroupKind() schema.GroupKind

ReplicaSetGroupKind returns group kind.

func STSStatusChange

func STSStatusChange(appGroupKind schema.GroupKind) predicate.Funcs

STSStatusChange monitors per application size change.

func VrouterActiveChange

func VrouterActiveChange() predicate.Funcs

VrouterActiveChange returns predicate function based on group kind.

func VrouterGroupKind

func VrouterGroupKind() schema.GroupKind

VrouterGroupKind returns group kind.

func WebuiGroupKind

func WebuiGroupKind() schema.GroupKind

WebuiGroupKind returns group kind.

func ZookeeperActiveChange

func ZookeeperActiveChange() predicate.Funcs

ZookeeperActiveChange returns predicate function based on group kind.

func ZookeeperGroupKind

func ZookeeperGroupKind() schema.GroupKind

ZookeeperGroupKind returns group kind.

Types

This section is empty.

Jump to

Keyboard shortcuts

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