util

Documentation

Index

• Constants
• func ConfigMapNameForBookie(clusterName string) string
• func ConfigMapNameForController(clusterName string) string
• func ConfigMapNameForSegmentstore(clusterName string) string
• func ContainsString(slice []string, str string) bool
• func DeleteAllZnodes(p *v1alpha1.PravegaCluster) (err error)
• func DeploymentNameForController(clusterName string) string
• func DownwardAPIEnv() []corev1.EnvVar
• func GetClusterExpectedSize(p *v1alpha1.PravegaCluster) (size int)
• func HeadlessServiceNameForBookie(clusterName string) string
• func HeadlessServiceNameForSegmentStore(clusterName string) string
• func HealthcheckCommand(port int32) []string
• func IsPodReady(pod *corev1.Pod) bool
• func LabelsForBookie(pravegaCluster *v1alpha1.PravegaCluster) map[string]string
• func LabelsForController(pravegaCluster *v1alpha1.PravegaCluster) map[string]string
• func LabelsForPravegaCluster(pravegaCluster *v1alpha1.PravegaCluster) map[string]string
• func LabelsForSegmentStore(pravegaCluster *v1alpha1.PravegaCluster) map[string]string
• func ListSubTreeBFS(conn *zk.Conn, root string) (*list.List, error)
• func Min(x, y int32) int32
• func PdbNameForBookie(clusterName string) string
• func PdbNameForController(clusterName string) string
• func PdbNameForSegmentstore(clusterName string) string
• func PodAntiAffinity(component string, clusterName string) *corev1.Affinity
• func PravegaControllerServiceURL(pravegaCluster v1alpha1.PravegaCluster) string
• func PvcIsOrphan(stsPvcName string, replicas int32) bool
• func RemoveString(slice []string, str string) (result []string)
• func ServiceNameForController(clusterName string) string
• func ServiceNameForSegmentStore(clusterName string, index int32) string
• func StatefulSetNameForBookie(clusterName string) string
• func StatefulSetNameForSegmentstore(clusterName string) string
• func WaitForClusterToTerminate(kubeClient client.Client, p *v1alpha1.PravegaCluster) (err error)

Constants

const (
	// Set in https://github.com/pravega/pravega/blob/master/docker/bookkeeper/entrypoint.sh#L21
	PravegaPath = "pravega"
	ZkFinalizer = "cleanUpZookeeper"
)

Functions

func ConfigMapNameForBookie

func ConfigMapNameForBookie(clusterName string) string

func ConfigMapNameForController

func ConfigMapNameForController(clusterName string) string

func ConfigMapNameForSegmentstore

func ConfigMapNameForSegmentstore(clusterName string) string

func ContainsString

func ContainsString(slice []string, str string) bool

func DeleteAllZnodes

func DeleteAllZnodes(p *v1alpha1.PravegaCluster) (err error)

Delete all znodes related to a specific Pravega cluster

func DeploymentNameForController

func DeploymentNameForController(clusterName string) string

func DownwardAPIEnv

func DownwardAPIEnv() []corev1.EnvVar

func GetClusterExpectedSize

func GetClusterExpectedSize(p *v1alpha1.PravegaCluster) (size int)

func HeadlessServiceNameForBookie

func HeadlessServiceNameForBookie(clusterName string) string

func HeadlessServiceNameForSegmentStore

func HeadlessServiceNameForSegmentStore(clusterName string) string

func HealthcheckCommand

func HealthcheckCommand(port int32) []string

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

func LabelsForBookie

func LabelsForBookie(pravegaCluster *v1alpha1.PravegaCluster) map[string]string

func LabelsForController

func LabelsForController(pravegaCluster *v1alpha1.PravegaCluster) map[string]string

func LabelsForPravegaCluster

func LabelsForPravegaCluster(pravegaCluster *v1alpha1.PravegaCluster) map[string]string

func LabelsForSegmentStore

func LabelsForSegmentStore(pravegaCluster *v1alpha1.PravegaCluster) map[string]string

func ListSubTreeBFS

func ListSubTreeBFS(conn *zk.Conn, root string) (*list.List, error)

Construct a BFS tree

func Min

func Min(x, y int32) int32

Min returns the smaller of x or y.

func PdbNameForBookie

func PdbNameForBookie(clusterName string) string

func PdbNameForController

func PdbNameForController(clusterName string) string

func PdbNameForSegmentstore

func PdbNameForSegmentstore(clusterName string) string

func PodAntiAffinity

func PodAntiAffinity(component string, clusterName string) *corev1.Affinity

func PravegaControllerServiceURL

func PravegaControllerServiceURL(pravegaCluster v1alpha1.PravegaCluster) string

func PvcIsOrphan

func PvcIsOrphan(stsPvcName string, replicas int32) bool

func RemoveString

func RemoveString(slice []string, str string) (result []string)

func ServiceNameForController

func ServiceNameForController(clusterName string) string

func ServiceNameForSegmentStore

func ServiceNameForSegmentStore(clusterName string, index int32) string

func StatefulSetNameForBookie

func StatefulSetNameForBookie(clusterName string) string

func StatefulSetNameForSegmentstore

func StatefulSetNameForSegmentstore(clusterName string) string

func WaitForClusterToTerminate

func WaitForClusterToTerminate(kubeClient client.Client, p *v1alpha1.PravegaCluster) (err error)

Wait for pods in cluster to be terminated