v0.5.7 Latest Latest

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

Go to latest
Published: Jun 23, 2023 License: Apache-2.0 Imports: 18 Imported by: 0




View Source
const (
	// Set in https://github.com/pravega/pravega/blob/master/docker/bookkeeper/entrypoint.sh#L21
	PravegaPath = "pravega"
	ZkFinalizer = "cleanUpZookeeper"
View Source
const (
	MajorMinorVersionRegexp string = `^v?(?P<Version>[0-9]+\.[0-9]+\.[0-9]+)`


This section is empty.


func BecomeLeader added in v0.5.6

func BecomeLeader(ctx context.Context, cfg *rest.Config, lockName, namespace string) error

BecomeLeader with pre-check cluster status - is there a previous pod in bad state?

func CompareConfigMap added in v0.5.2

func CompareConfigMap(cm1 *corev1.ConfigMap, cm2 *corev1.ConfigMap) bool

func CompareVersions

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

func ContainsString

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

func ContainsVersion

func ContainsVersion(list []string, version string) bool

func ControllerReadinessCheck added in v0.5.1

func ControllerReadinessCheck(version string, port int32, authflag bool) []string

func DeleteAllZnodes

func DeleteAllZnodes(zkUri string, clusterName string) (err error)

Delete all znodes related to a specific Pravega cluster

func DownwardAPIEnv

func DownwardAPIEnv() []corev1.EnvVar

func GenerateJVMOption added in v0.4.2

func GenerateJVMOption(k, v string) string

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

func GetPodVersion

func GetPodVersion(pod *v1.Pod) string

func HealthcheckCommand

func HealthcheckCommand(version string, port int32, restport int32) []string

func IsOrphan added in v0.4.3

func IsOrphan(k8sObjectName string, replicas int32) bool

func IsPodFaulty added in v0.4.2

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

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

func IsPravegaContainer added in v0.5.3

func IsPravegaContainer(container corev1.ContainerStatus) bool

func IsVersionBelow added in v0.5.5

func IsVersionBelow(v1 string, v2 string) bool

function to check if v1 is below v2 or not

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 NormalizeVersion

func NormalizeVersion(version string) (string, error)

func OverrideDefaultJVMOptions added in v0.4.2

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

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

func PodAntiAffinity

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

func RemoveString

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

func SegmentStoreReadinessCheck added in v0.5.5

func SegmentStoreReadinessCheck(version string, port int32, restport int32) []string

func UpdateOneJVMOption added in v0.4.2

func UpdateOneJVMOption(arg string, om *OrderedMap)

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


type OrderedMap added in v0.4.2

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.

Jump to

Keyboard shortcuts

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