e2eutil

Documentation

Index

• func CheckAgentLog(namespace, name string, dynclient client.Client) (string, error)
• func CheckManagerLog(namespace, name string) (string, error)
• func CleanEIPList(dynclient client.Client) error
• func Connect(user, password, host, key string, port int, cipherList []string) (*ssh.Session, error)
• func GetDefaultPrivateKeyFile() string
• func GetLogOfPod(rest *rest.RESTClient, namespace, name string, ...) error
• func GetServiceNodesIP(c client.Client, namespace, name string) ([]string, error)
• func QuickConnectAndRun(host, cmd string) ([]byte, error)
• func QuickConnectUsingDefaultSSHKey(host string) (*ssh.Session, error)
• func WaitForController(c client.Client, namespace, name string, retryInterval, timeout time.Duration) error
• func WaitForDeletion(dynclient client.Client, obj runtime.Object, ...) error
• type LogInfo
  • func ParseLog(log string) *LogInfo

Functions

func CheckAgentLog

func CheckAgentLog(namespace, name string, dynclient client.Client) (string, error)

func CheckManagerLog

func CheckManagerLog(namespace, name string) (string, error)

func CleanEIPList

func CleanEIPList(dynclient client.Client) error

func Connect

func Connect(user, password, host, key string, port int, cipherList []string) (*ssh.Session, error)

func GetDefaultPrivateKeyFile

func GetDefaultPrivateKeyFile() string

func GetLogOfPod

func GetLogOfPod(rest *rest.RESTClient, namespace, name string, logOptions *corev1.PodLogOptions, out io.Writer) error

func GetServiceNodesIP

func GetServiceNodesIP(c client.Client, namespace, name string) ([]string, error)

func QuickConnectAndRun

func QuickConnectAndRun(host, cmd string) ([]byte, error)

func QuickConnectUsingDefaultSSHKey

func QuickConnectUsingDefaultSSHKey(host string) (*ssh.Session, error)

func WaitForController

func WaitForController(c client.Client, namespace, name string, retryInterval, timeout time.Duration) error

func WaitForDeletion

func WaitForDeletion(dynclient client.Client, obj runtime.Object, retryInterval, timeout time.Duration) error

Types

type LogInfo

type LogInfo struct {
	Level  string  `json:"level,omitempty"`
	TS     float64 `json:"ts,omitempty"`
	Logger string  `json:"logger,omitempty"`
	Msg    string  `json:"msg,omitempty"`
}

func ParseLog

func ParseLog(log string) *LogInfo