util

Documentation

Index

• Constants
• func BookkeeperImage(p *v1alpha1.PravegaCluster) (image string)
• func BookkeeperTargetImage(p *v1alpha1.PravegaCluster) (string, error)
• func CompareVersions(v1, v2, operator string) (bool, error)
• func ConfigMapNameForBookie(clusterName string) string
• func ConfigMapNameForController(clusterName string) string
• func ConfigMapNameForSegmentstore(clusterName string) string
• func ContainsString(slice []string, str string) bool
• func ContainsVersion(list []string, version string) bool
• func DeleteAllZnodes(p *v1alpha1.PravegaCluster) (err error)
• func DeploymentNameForController(clusterName string) string
• func DownwardAPIEnv() []corev1.EnvVar
• func GenerateJVMOption(k, v string) string
• func GetClusterExpectedSize(p *v1alpha1.PravegaCluster) (size int)
• func GetPodVersion(pod *v1.Pod) string
• func HeadlessServiceNameForBookie(clusterName string) string
• func HeadlessServiceNameForSegmentStore(clusterName string) string
• func HealthcheckCommand(port int32) []string
• func IsOrphan(k8sObjectName string, replicas int32) bool
• func IsPodFaulty(pod *corev1.Pod) (bool, error)
• 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 NewEvent(name string, p *v1alpha1.PravegaCluster, reason string, message string, ...) *corev1.Event
• func NormalizeVersion(version string) (string, error)
• func OverrideDefaultJVMOptions(defaultOpts []string, customOpts []string) []string
• 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 PravegaImage(p *v1alpha1.PravegaCluster) (image string)
• func PravegaTargetImage(p *v1alpha1.PravegaCluster) (string, error)
• 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 UpdateOneJVMOption(arg string, om *OrderedMap)
• func WaitForClusterToTerminate(kubeClient client.Client, p *v1alpha1.PravegaCluster) (err error)
• type OrderedMap

Constants

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

const (
	MajorMinorVersionRegexp string = `^v?(?P<Version>[0-9]+\.[0-9]+\.[0-9]+)`
)

Functions

func BookkeeperImage

func BookkeeperImage(p *v1alpha1.PravegaCluster) (image string)

func BookkeeperTargetImage

func BookkeeperTargetImage(p *v1alpha1.PravegaCluster) (string, error)

func CompareVersions

func CompareVersions(v1, v2, operator string) (bool, error)

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 ContainsVersion

func ContainsVersion(list []string, version 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 GenerateJVMOption

func GenerateJVMOption(k, v string) string

Concatenate the key value pair to be a JVM option string.

func GetClusterExpectedSize

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

func GetPodVersion

func GetPodVersion(pod *v1.Pod) string

func HeadlessServiceNameForBookie

func HeadlessServiceNameForBookie(clusterName string) string

func HeadlessServiceNameForSegmentStore

func HeadlessServiceNameForSegmentStore(clusterName string) string

func HealthcheckCommand

func HealthcheckCommand(port int32) []string

func IsOrphan

func IsOrphan(k8sObjectName string, replicas int32) bool

func IsPodFaulty

func IsPodFaulty(pod *corev1.Pod) (bool, error)

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 NewEvent

func NewEvent(name string, p *v1alpha1.PravegaCluster, reason string, message string, eventType string) *corev1.Event

func NormalizeVersion

func NormalizeVersion(version string) (string, error)

func OverrideDefaultJVMOptions

func OverrideDefaultJVMOptions(defaultOpts []string, customOpts []string) []string

This method will override the default JVM options with user provided custom options

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 PravegaImage

func PravegaImage(p *v1alpha1.PravegaCluster) (image string)

func PravegaTargetImage

func PravegaTargetImage(p *v1alpha1.PravegaCluster) (string, error)

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 UpdateOneJVMOption

func UpdateOneJVMOption(arg string, om *OrderedMap)

This method will parse the JVM options into a key value pair and store it in the OrderedMap

func WaitForClusterToTerminate

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

Wait for pods in cluster to be terminated

Types

type OrderedMap

type OrderedMap struct {
	// contains filtered or unexported fields
}

OrderedMap is a map that has insertion order when iterating. The iteration of map in GO is in random order by default.