util

package

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pravega/pravega-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BecomeLeader(ctx context.Context, cfg *rest.Config, lockName, namespace string) error
func CompareConfigMap(cm1 *corev1.ConfigMap, cm2 *corev1.ConfigMap) bool
func CompareVersions(v1, v2, operator string) (bool, error)
func ContainsString(slice []string, str string) bool
func ContainsVersion(list []string, version string) bool
func ControllerReadinessCheck(version string, port int32, authflag bool) []string
func DeleteAllZnodes(zkUri string, clusterName string) (err error)
func DownwardAPIEnv() []corev1.EnvVar
func GenerateJVMOption(k, v string) string
func GetPodVersion(pod *v1.Pod) string
func HealthcheckCommand(version string, port int32, restport int32) []string
func IsOrphan(k8sObjectName string, replicas int32) bool
func IsPodFaulty(pod *corev1.Pod) (bool, error)
func IsPodReady(pod *corev1.Pod) bool
func IsPravegaContainer(container corev1.ContainerStatus) bool
func IsVersionBelow(v1 string, v2 string) bool
func ListSubTreeBFS(conn *zk.Conn, root string) (*list.List, error)
func Min(x, y int32) int32
func NormalizeVersion(version string) (string, error)
func OverrideDefaultJVMOptions(defaultOpts []string, customOpts []string) []string
func PodAntiAffinity(component string, clusterName string) *corev1.Affinity
func RemoveString(slice []string, str string) (result []string)
func SegmentStoreReadinessCheck(version string, port int32, restport int32) []string
func UpdateOneJVMOption(arg string, om *OrderedMap)
type OrderedMap

Constants ¶

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]+)`
)

Variables ¶

This section is empty.

Functions ¶

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

Types ¶

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.

Source Files ¶

View all Source files

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