commands

Documentation

Index

• Constants
• func GetPod(ctx context.Context, client *kubernetes.Clientset, namespace, name string, ...) (*corev1.Pod, error)
• func LoadAuthInfo(c *cli.Context, ctx context.Context) (*redis.AuthInfo, error)
• func LoadMonitorAuthInfo(c *cli.Context, ctx context.Context, client *kubernetes.Clientset) (*redis.AuthInfo, error)
• func LoadTLSCofig(tlsKeyFile, tlsCertFile string) (*tls.Config, error)
• func NewOwnerReference(ctx context.Context, client *kubernetes.Clientset, namespace, podName string) ([]metav1.OwnerReference, error)
• func RetryGet(f func() error, steps ...int) error
• func RetryGetService(ctx context.Context, clientset *kubernetes.Clientset, ...) (*corev1.Service, error)

Constants

const (
	DefaultSecretMountPath = "/account/password" // #nosec G101
	InjectedPasswordPath   = "/tmp/newpass"      // #nosec G101
)

Functions

func GetPod

func GetPod(ctx context.Context, client *kubernetes.Clientset, namespace, name string, logger logr.Logger) (*corev1.Pod, error)

func LoadAuthInfo

func LoadAuthInfo(c *cli.Context, ctx context.Context) (*redis.AuthInfo, error)

func LoadMonitorAuthInfo

func LoadMonitorAuthInfo(c *cli.Context, ctx context.Context, client *kubernetes.Clientset) (*redis.AuthInfo, error)

func LoadTLSCofig

func LoadTLSCofig(tlsKeyFile, tlsCertFile string) (*tls.Config, error)

func NewOwnerReference

func NewOwnerReference(ctx context.Context, client *kubernetes.Clientset, namespace, podName string) ([]metav1.OwnerReference, error)

NewOwnerReference

func RetryGet

func RetryGet(f func() error, steps ...int) error

func RetryGetService

func RetryGetService(ctx context.Context, clientset *kubernetes.Clientset, svcNamespace, svcName string, typ corev1.ServiceType,
	count int, logger logr.Logger) (*corev1.Service, error)