util

package
v0.0.0-...-704bf29 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AppKey     = "app"
	AtomixApp  = "atomix"
	ClusterKey = "cluster"
	TypeKey    = "type"
	GroupKey   = "group"
)
View Source 
const (
	ManagementType       = "management"
	GroupType            = "group"
	BenchWorkerType      = "benchmark-worker"
	BenchCoordinatorType = "benchmark-coordinator"
)
View Source 
const (
	ServiceSuffix          = "service"
	DisruptionBudgetSuffix = "pdb"
	InitSuffix             = "init"
	ConfigSuffix           = "config"
	BenchmarkSuffix        = "bench"
	WorkerSuffix           = "worker"
)
View Source 
const (
	InitScriptsVolume  = "init-scripts"
	UserConfigVolume   = "user-config"
	SystemConfigVolume = "system-config"
	DataVolume         = "data"
)

Variables

This section is empty.

Functions

func GetBenchmarkControllerInitConfigMapName 

func GetBenchmarkControllerInitConfigMapName(benchmark *v1alpha1.AtomixBenchmark) string

func GetBenchmarkControllerPodName 

func GetBenchmarkControllerPodName(benchmark *v1alpha1.AtomixBenchmark) string

func GetBenchmarkControllerServiceName 

func GetBenchmarkControllerServiceName(benchmark *v1alpha1.AtomixBenchmark) string

func GetBenchmarkControllerSystemConfigMapName 

func GetBenchmarkControllerSystemConfigMapName(benchmark *v1alpha1.AtomixBenchmark) string

func GetBenchmarkWorkerInitConfigMapName 

func GetBenchmarkWorkerInitConfigMapName(benchmark *v1alpha1.AtomixBenchmark) string

func GetBenchmarkWorkerServiceName 

func GetBenchmarkWorkerServiceName(benchmark *v1alpha1.AtomixBenchmark) string

func GetBenchmarkWorkerStatefulSetName 

func GetBenchmarkWorkerStatefulSetName(benchmark *v1alpha1.AtomixBenchmark) string

func GetBenchmarkWorkerSystemConfigMapName 

func GetBenchmarkWorkerSystemConfigMapName(benchmark *v1alpha1.AtomixBenchmark) string

func GetManagementDisruptionBudgetName 

func GetManagementDisruptionBudgetName(cluster *v1alpha1.AtomixCluster) string

func GetManagementInitConfigMapName 

func GetManagementInitConfigMapName(cluster *v1alpha1.AtomixCluster) string

func GetManagementServiceName 

func GetManagementServiceName(cluster *v1alpha1.AtomixCluster) string

func GetManagementStatefulSetName 

func GetManagementStatefulSetName(cluster *v1alpha1.AtomixCluster) string

func GetManagementSystemConfigMapName 

func GetManagementSystemConfigMapName(cluster *v1alpha1.AtomixCluster) string

func GetPartitionGroupDisruptionBudgetName 

func GetPartitionGroupDisruptionBudgetName(group *v1alpha1.PartitionGroup) string

func GetPartitionGroupInitConfigMapName 

func GetPartitionGroupInitConfigMapName(group *v1alpha1.PartitionGroup) string

func GetPartitionGroupServiceName 

func GetPartitionGroupServiceName(group *v1alpha1.PartitionGroup) string

func GetPartitionGroupStatefulSetName 

func GetPartitionGroupStatefulSetName(group *v1alpha1.PartitionGroup) string

func GetPartitionGroupSystemConfigMapName 

func GetPartitionGroupSystemConfigMapName(group *v1alpha1.PartitionGroup) string

func NewBenchmarkControllerInitConfigMap 

func NewBenchmarkControllerInitConfigMap(benchmark *v1alpha1.AtomixBenchmark) *corev1.ConfigMap

func NewBenchmarkControllerPod 

func NewBenchmarkControllerPod(benchmark *v1alpha1.AtomixBenchmark) *corev1.Pod

func NewBenchmarkControllerService 

func NewBenchmarkControllerService(benchmark *v1alpha1.AtomixBenchmark) *corev1.Service

func NewBenchmarkControllerSystemConfigMap 

func NewBenchmarkControllerSystemConfigMap(benchmark *v1alpha1.AtomixBenchmark) *corev1.ConfigMap

func NewBenchmarkWorkerInitConfigMap 

func NewBenchmarkWorkerInitConfigMap(benchmark *v1alpha1.AtomixBenchmark) *corev1.ConfigMap

func NewBenchmarkWorkerService 

func NewBenchmarkWorkerService(benchmark *v1alpha1.AtomixBenchmark) *corev1.Service

func NewBenchmarkWorkerStatefulSet 

func NewBenchmarkWorkerStatefulSet(benchmark *v1alpha1.AtomixBenchmark) *appsv1.StatefulSet

func NewBenchmarkWorkerSystemConfigMap 

func NewBenchmarkWorkerSystemConfigMap(benchmark *v1alpha1.AtomixBenchmark) *corev1.ConfigMap

func NewManagementDisruptionBudget 

func NewManagementDisruptionBudget(cluster *v1alpha1.AtomixCluster) *v1beta1.PodDisruptionBudget

NewManagementDisruptionBudget returns a new pod disruption budget for the Management cluster

func NewManagementInitConfigMap 

func NewManagementInitConfigMap(cluster *v1alpha1.AtomixCluster) *corev1.ConfigMap

NewManagementInitConfigMap returns a new ConfigMap for initializing Atomix clusters

func NewManagementService 

func NewManagementService(cluster *v1alpha1.AtomixCluster) *corev1.Service

NewManagementService returns a new headless service for the Atomix cluster

func NewManagementStatefulSet 

func NewManagementStatefulSet(cluster *v1alpha1.AtomixCluster) (*appsv1.StatefulSet, error)

NewManagementStatefulSet returns a StatefulSet for a management cluster

func NewManagementSystemConfigMap 

func NewManagementSystemConfigMap(cluster *v1alpha1.AtomixCluster) *corev1.ConfigMap

NewManagementSystemConfigMap returns a new ConfigMap for the management cluster

func NewPartitionGroupConfigMap 

func NewPartitionGroupConfigMap(group *v1alpha1.PartitionGroup) (*corev1.ConfigMap, error)

NewPartitionGroupConfigMap returns a new ConfigMap for a Raft partition group StatefulSet

func NewPartitionGroupDisruptionBudget 

func NewPartitionGroupDisruptionBudget(group *v1alpha1.PartitionGroup) *v1beta1.PodDisruptionBudget

NewPartitionGroupDisruptionBudget returns a new pod disruption budget for the partition group cluster

func NewPartitionGroupInitConfigMap 

func NewPartitionGroupInitConfigMap(group *v1alpha1.PartitionGroup) *corev1.ConfigMap

NewPartitionGroupInitConfigMap returns a new ConfigMap for initializing Atomix clusters

func NewPartitionGroupService 

func NewPartitionGroupService(group *v1alpha1.PartitionGroup) *corev1.Service

NewPartitionGroupService returns a new headless service for a partition group

func NewPartitionGroupStatefulSet 

func NewPartitionGroupStatefulSet(group *v1alpha1.PartitionGroup) (*appsv1.StatefulSet, error)

NewPartitionGroupConfigMap returns a new StatefulSet for a partition group

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.