Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

util

package

Go to main page

Versions in this module

v0

v0.1.9

Jun 23, 2023

v0.1.8

May 13, 2022

v0.1.7

Nov 23, 2021

Changes in this version

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

v0.1.6

Sep 22, 2021

v0.1.5

Jul 6, 2021

v0.1.4

May 26, 2021

Changes in this version

+ func CompareConfigMap(cm1 *v1.ConfigMap, cm2 *v1.ConfigMap) bool

v0.1.3

Nov 11, 2020

v0.1.3-rc2

Nov 11, 2020

v0.1.3-rc1

Oct 21, 2020

v0.1.3-rc0

Oct 1, 2020

v0.1.2

Aug 12, 2020

v0.1.2-rc1

Jul 8, 2020

v0.1.2-rc0

Jun 10, 2020

v0.1.1

Apr 30, 2020

Changes in this version

+ const MajorMinorVersionRegexp

+ const PravegaPath

+ const ZkFinalizer

+ func BookkeeperImage(p *v1alpha1.BookkeeperCluster) (image string)

+ func BookkeeperTargetImage(p *v1alpha1.BookkeeperCluster) (string, error)

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

+ func ConfigMapNameForBookie(clusterName string) string

+ func ContainsStringWithPrefix(slice []string, str string) bool

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

+ func DeleteAllZnodes(bk *v1alpha1.BookkeeperCluster, pravegaClusterName string) (err error)

+ func DownwardAPIEnv() []corev1.EnvVar

+ func GenerateJVMOption(k, v string) string

+ func GetClusterExpectedSize(p *v1alpha1.BookkeeperCluster) (size int)

+ func GetPodVersion(pod *v1.Pod) string

+ func GetStringWithPrefix(slice []string, str string) (result string)

+ func HeadlessServiceNameForBookie(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(bookkeeperCluster *v1alpha1.BookkeeperCluster) map[string]string

+ func LabelsForBookkeeperCluster(bookkeeperCluster *v1alpha1.BookkeeperCluster) map[string]string

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

+ func Min(x, y int32) int32

+ func NewApplicationEvent(name string, p *v1alpha1.BookkeeperCluster, reason string, message string, ...) *corev1.Event

+ func NewEvent(name string, p *v1alpha1.BookkeeperCluster, 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 PodAntiAffinity(component string, clusterName string) *corev1.Affinity

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

+ func StatefulSetNameForBookie(clusterName string) string

+ func UpdateOneJVMOption(arg string, om *OrderedMap)

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

+ type OrderedMap struct

v0.1.1-rc2

Apr 29, 2020

v0.1.1-rc1

Apr 21, 2020

v0.1.1-rc0

Mar 24, 2020