e2eutil

Documentation

Index

• Constants
• func CheckAgentLog(namespace, name, logfileName string, dynclient client.Client) (string, error)
• func CheckManagerLog(namespace, name, logfileName string) (string, error)
• func CleanEIPList(dynclient client.Client) error
• func Connect(user, password, host, key string, port int, cipherList []string) (*ssh.Session, error)
• func DeleteNamespace(c client.Client, ns string) error
• func EnsureNamespaceClean(nsname string) error
• func GetContainerLog(containerID string) (string, error)
• func GetDefaultPrivateKeyFile() string
• func GetLogOfPod(rest *rest.RESTClient, namespace, name string, ...) error
• func GetServiceNodesIP(c client.Client, namespaceName types.NamespacedName) ([]string, error)
• func KubectlApply(filename string) error
• func KubectlDelete(filename string) error
• func QuickConnectAndRun(host, cmd string) ([]byte, error)
• func QuickConnectUsingDefaultSSHKey(host string) (*ssh.Session, error)
• func RunGoBGPContainer(configPath string) (string, error)
• func ScpFileToRemote(source, dst, host string) error
• func StopGoBGPContainer(containerID string) error
• func WaitForController(c client.Client, namespace, name string, retryInterval, timeout time.Duration) error
• func WaitForDeletion(dynclient client.Client, obj runtime.Object, ...) error
• type DeployFunc
• type LogInfo
  • func ParseLog(log string) *LogInfo
• type TestCase
  • func (t *TestCase) CheckBGPRoute() (string, error)
  • func (t *TestCase) CheckNetwork()
  • func (t *TestCase) DeleteController() error
  • func (t *TestCase) DeleteServiceGracefully(service *corev1.Service) error
  • func (t *TestCase) DeployYaml() error
  • func (t *TestCase) GenerateControllerConfig() (string, error)
  • func (t *TestCase) GetRouterLog() (string, error)
  • func (t *TestCase) IsLocal() bool
  • func (t *TestCase) ReplaceConfigMap() error
  • func (t *TestCase) SetRouterContainerID(id string)
  • func (t *TestCase) StartDefaultTest(workspace string)
  • func (t *TestCase) StartRemoteRoute() error
  • func (t *TestCase) StopRouter() error
  • func (t *TestCase) WaitForControllerUp() error
  • func (t *TestCase) WriteConfig(temppath, output string) error
• type TestFunc

Constants

const (
	BGPImageName = "magicsong/gobgp"
)

Functions

func CheckAgentLog

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

func CheckManagerLog

func CheckManagerLog(namespace, name, logfileName 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 DeleteNamespace

func DeleteNamespace(c client.Client, ns string) error

func EnsureNamespaceClean

func EnsureNamespaceClean(nsname string) error

func GetContainerLog

func GetContainerLog(containerID string) (string, 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, namespaceName types.NamespacedName) ([]string, error)

func KubectlApply

func KubectlApply(filename string) error

func KubectlDelete

func KubectlDelete(filename string) error

func QuickConnectAndRun

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

func QuickConnectUsingDefaultSSHKey

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

func RunGoBGPContainer

func RunGoBGPContainer(configPath string) (string, error)

func ScpFileToRemote

func ScpFileToRemote(source, dst, host string) error

func StopGoBGPContainer

func StopGoBGPContainer(containerID string) 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 DeployFunc

type DeployFunc func() error

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

type TestCase

type TestCase struct {
	Name           string
	ControllerAS   int
	ControllerIP   string
	ControllerPort int
	ControllerName string

	RouterIP               string
	RouterAS               int
	UsePortForward         bool
	RouterConfigPath       string
	ControllerConfigPath   string
	IsPassiveMode          bool
	RouterTemplatePath     string
	ControllerTemplatePath string
	Namespace              string
	K8sClient              client.Client
	KustomizePath          string

	DeployYamlPath string

	TestDeploymentName string

	InjectTest TestFunc
	// contains filtered or unexported fields
}

func (*TestCase) CheckBGPRoute

func (t *TestCase) CheckBGPRoute() (string, error)

func (*TestCase) CheckNetwork

func (t *TestCase) CheckNetwork()

func (*TestCase) DeleteController

func (t *TestCase) DeleteController() error

func (*TestCase) DeleteServiceGracefully

func (t *TestCase) DeleteServiceGracefully(service *corev1.Service) error

func (*TestCase) DeployYaml

func (t *TestCase) DeployYaml() error

func (*TestCase) GenerateControllerConfig

func (t *TestCase) GenerateControllerConfig() (string, error)

func (*TestCase) GetRouterLog

func (t *TestCase) GetRouterLog() (string, error)

func (*TestCase) IsLocal

func (t *TestCase) IsLocal() bool

func (*TestCase) ReplaceConfigMap

func (t *TestCase) ReplaceConfigMap() error

func (*TestCase) SetRouterContainerID

func (t *TestCase) SetRouterContainerID(id string)

func (*TestCase) StartDefaultTest

func (t *TestCase) StartDefaultTest(workspace string)

Change configure of TestCase to test some behabiour

func (*TestCase) StartRemoteRoute

func (t *TestCase) StartRemoteRoute() error

func (*TestCase) StopRouter

func (t *TestCase) StopRouter() error

func (*TestCase) WaitForControllerUp

func (t *TestCase) WaitForControllerUp() error

func (*TestCase) WriteConfig

func (t *TestCase) WriteConfig(temppath, output string) error

type TestFunc

type TestFunc func()