Versions in this module Expand all Collapse all v0 v0.6.0 Jun 14, 2024 Changes in this version + const NetworkFailure + const OpenELBNamespace + const PauseImage + const PodStartTimeout + var ErrFailure error = FailureError + var Fail = ginkgo.Fail + func Do(address string) error + func ExpectConsistOf(actual interface{}, extra interface{}, explain ...interface{}) + func ExpectEmpty(actual interface{}, explain ...interface{}) + func ExpectEqual(actual interface{}, extra interface{}, explain ...interface{}) + func ExpectError(err error, explain ...interface{}) + func ExpectFalse(actual interface{}, explain ...interface{}) + func ExpectHaveKey(actual interface{}, key interface{}, explain ...interface{}) + func ExpectNil(actual interface{}, explain ...interface{}) + func ExpectNoError(err error, explain ...interface{}) + func ExpectNoErrorWithOffset(offset int, err error, explain ...interface{}) + func ExpectNotEqual(actual interface{}, extra interface{}, explain ...interface{}) + func ExpectNotNil(actual interface{}, explain ...interface{}) + func ExpectTrue(actual interface{}, explain ...interface{}) + func Failf(format string, args ...interface{}) + func KubesphereDescribe(text string, body func()) bool + func Logf(format string, args ...interface{}) + func MakePod(ns, name string, labels, annotations map[string]string, image string, ...) *corev1.Pod + func WaitDaemonsetPresentFitWith(client client.Client, namespace, name string, ...) + func WaitDeploymentPresentFitWith(client client.Client, namespace, name string, ...) + func WaitForBGPEstablished(timeout time.Duration, bgpClient *GobgpClient, num int) error + func WaitForRouterNum(timeout time.Duration, ip string, bgpClient *GobgpClient, num int) error + func WaitServicePresentFitWith(client client.Client, namespace, name string, ...) + type BgpConfGlobal struct + AS uint32 + Client client.Client + ListenPort int32 + Name string + RouterID string + func (b *BgpConfGlobal) Create(ctx context.Context) error + func (b *BgpConfGlobal) Delete(ctx context.Context) error + func (b *BgpConfGlobal) Update(ctx context.Context, listenPort int32) error + type BgpPeer struct + AS uint32 + Address string + Client client.Client + Name string + Passive bool + Port uint32 + func (b *BgpPeer) Create(ctx context.Context) error + func (b *BgpPeer) Delete(ctx context.Context) error + func (b *BgpPeer) Update(ctx context.Context) error + type FailureError struct + func (f FailureError) Backtrace() string + func (f FailureError) Error() string + func (f FailureError) Is(target error) bool + type Framework struct + KubeConfig string + OpenELBClient client.Client + Scheme *runtime.Scheme + func NewDefaultFramework(baseName string) *Framework + func (f *Framework) BeforeEach() + func (f *Framework) PodClient() *PodClient + func (f *Framework) PodClientNS(namespace string) *PodClient + type GobgpClient struct + func NewGobgpClient(ctx context.Context, pod *v1.Pod, port int) *GobgpClient + func (c *GobgpClient) AddConfForGobgp(routerid string, as uint32, port int32) error + func (c *GobgpClient) AddPeerForGobgp(address string, as uint32, port int) error + func (c *GobgpClient) DeletePeerForGobgp(address string) error + func (c *GobgpClient) GetAllPeers() ([]*gobgpapi.Peer, error) + func (c *GobgpClient) GetRoutersForGobgp(ip string) (map[string]struct{}, error) + type PodClient struct + func (c *PodClient) Create(ctx context.Context, pod *corev1.Pod) *corev1.Pod + func (c *PodClient) CreateSync(ctx context.Context, pod *corev1.Pod) *corev1.Pod + func (c *PodClient) Delete(ctx context.Context, name string) error + func (c *PodClient) DeleteSync(ctx context.Context, name string) + func (c *PodClient) WaitForNotFound(ctx context.Context, name string) + func (c *PodClient) WaitForRunning(ctx context.Context, name string)
Go to main page