package util

import "k8s.io/apiserver/pkg/storage/etcd/util"

Package util holds generic etcd-related utility functions that any user of ectd might want to use, without pulling in kubernetes-specific code.

Index ¶

• func EtcdHealthCheck(data []byte) error
• func GetEtcdVersion(host string) (string, error)
• func IsEtcdNodeExist(err error) bool
• func IsEtcdNotFound(err error) bool
• func IsEtcdTestFailed(err error) bool
• func IsEtcdUnreachable(err error) bool
• func IsEtcdWatchExpired(err error) bool

Functions ¶

func EtcdHealthCheck ¶

func EtcdHealthCheck(data []byte) error

func GetEtcdVersion ¶

func GetEtcdVersion(host string) (string, error)

GetEtcdVersion performs a version check against the provided Etcd server, returning the string response, and error (if any).

func IsEtcdNodeExist ¶

func IsEtcdNodeExist(err error) bool

IsEtcdNodeExist returns true if and only if err is an etcd node already exist error.

func IsEtcdNotFound ¶

func IsEtcdNotFound(err error) bool

IsEtcdNotFound returns true if and only if err is an etcd not found error.

func IsEtcdTestFailed ¶

func IsEtcdTestFailed(err error) bool

IsEtcdTestFailed returns true if and only if err is an etcd write conflict.

func IsEtcdUnreachable ¶

func IsEtcdUnreachable(err error) bool

IsEtcdUnreachable returns true if and only if err indicates the server could not be reached.

func IsEtcdWatchExpired ¶

func IsEtcdWatchExpired(err error) bool

IsEtcdWatchExpired returns true if and only if err indicates the watch has expired.

Source Files ¶

doc.go etcd_util.go