utils

Documentation

Index

• Constants
• Variables
• func BuildInfos()
• func GetKubeNodes(ctx context.Context, kubeClient client.Client, nodeSelector map[string]string) ([]corev1.Node, error)
• func GetNbPodsToCreate(cluster *rapi.RedisCluster) int32
• func GetZone(nodeName string, kubeNodes []corev1.Node) string
• func GetZoneSkew(zoneToNodes map[string][]string) int
• func GetZoneSkewByRole(zoneToPrimaries map[string][]string, zoneToReplicas map[string][]string) (int, int, bool)
• func GetZones(nodes []corev1.Node) []string
• func IsPodReady(pod *corev1.Pod) (bool, error)
• func ListPods(ctx context.Context, kubeClient client.Client, opts []client.ListOption) ([]corev1.Pod, error)
• func SliceJoin(a []Stringer, sep string) string
• func StringToByteString(value string) (string, error)
• func ZoneToRole(nodes []rapi.RedisClusterNode) (map[string][]string, map[string][]string)
• type LogWriter
  • func NewLogWriter(f func(args ...interface{})) *LogWriter
  • func (w LogWriter) Write(p []byte) (n int, err error)
• type Stringer

Constants

const (
	Kilobyte = 1000
	Kibibyte = 1024
)

Variables

var BUILDTIME string

var OPERATOR_VERSION string

var REDIS_VERSION string

var REVISION string

Functions

func BuildInfos

func BuildInfos()

BuildInfos returns builds information

func GetKubeNodes

func GetKubeNodes(ctx context.Context, kubeClient client.Client, nodeSelector map[string]string) ([]corev1.Node, error)

func GetNbPodsToCreate

func GetNbPodsToCreate(cluster *rapi.RedisCluster) int32

func GetZone

func GetZone(nodeName string, kubeNodes []corev1.Node) string

func GetZoneSkew

func GetZoneSkew(zoneToNodes map[string][]string) int

func GetZoneSkewByRole

func GetZoneSkewByRole(zoneToPrimaries map[string][]string, zoneToReplicas map[string][]string) (int, int, bool)

func GetZones

func GetZones(nodes []corev1.Node) []string

func IsPodReady

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

IsPodReady check if pod is in ready condition, return the error message otherwise

func ListPods

func ListPods(ctx context.Context, kubeClient client.Client, opts []client.ListOption) ([]corev1.Pod, error)

func SliceJoin

func SliceJoin(a []Stringer, sep string) string

SliceJoin concatenates the elements of a to create a single string. The separator string sep is placed between elements in the resulting string.

func StringToByteString

func StringToByteString(value string) (string, error)

func ZoneToRole

func ZoneToRole(nodes []rapi.RedisClusterNode) (map[string][]string, map[string][]string)

Types

type LogWriter

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

LogWriter struct representation of a log writter, containing the pointer of the logging function

func NewLogWriter

func NewLogWriter(f func(args ...interface{})) *LogWriter

NewLogWriter create a new LogWriter with the pointer of the logging function in input

func (LogWriter) Write

func (w LogWriter) Write(p []byte) (n int, err error)

Write implements the standard Write interface: it writes using the logging function

type Stringer

type Stringer interface {
	String() string
}

Stringer implements the string interface