testing

package
v0.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Namespace      = "test-namespace"
	LocalClusterID = "local-cluster"
)
View Source 
const (
	EvTransitionToNonGateway = "TransitionToNonGateway"
	EvTransitionToGateway    = "TransitionToGateway"
	EvLocalEndpointCreated   = "LocalEndpointCreated"
	EvLocalEndpointUpdated   = "LocalEndpointUpdated"
	EvLocalEndpointRemoved   = "LocalEndpointRemoved"
	EvRemoteEndpointCreated  = "RemoteEndpointCreated"
	EvRemoteEndpointUpdated  = "RemoteEndpointUpdated"
	EvRemoteEndpointRemoved  = "RemoteEndpointRemoved"
	EvNodeCreated            = "NodeCreated"
	EvNodeUpdated            = "NodeUpdated"
	EvNodeRemoved            = "NodeRemoved"
	EvStop                   = "Stop"
	EvUninstall              = "Uninstall"
	EvInit                   = "Init"
)

Variables

This section is empty.

Functions

func NewEndpoint added in v0.17.0 

func NewEndpoint(clusterID, hostname string, subnets ...string) *submV1.Endpoint

func NewNode added in v0.17.0 

func NewNode(name string) *corev1.Node

Types

type ControllerSupport added in v0.17.0 

type ControllerSupport struct {
	Hostname string
	// contains filtered or unexported fields
}

func NewControllerSupport added in v0.17.0 

func NewControllerSupport() *ControllerSupport

func (*ControllerSupport) CreateEndpoint added in v0.17.0 

func (c *ControllerSupport) CreateEndpoint(endpoint *submV1.Endpoint) *submV1.Endpoint

func (*ControllerSupport) CreateLocalHostEndpoint added in v0.17.0 

func (c *ControllerSupport) CreateLocalHostEndpoint() *submV1.Endpoint

func (*ControllerSupport) CreateNode added in v0.17.0 

func (c *ControllerSupport) CreateNode(node *corev1.Node) *corev1.Node

func (*ControllerSupport) DeleteEndpoint added in v0.17.0 

func (c *ControllerSupport) DeleteEndpoint(name string)

func (*ControllerSupport) DeleteNode added in v0.17.0 

func (c *ControllerSupport) DeleteNode(name string)

func (*ControllerSupport) Start added in v0.17.0 

func (c *ControllerSupport) Start(handlers ...event.Handler)

func (*ControllerSupport) UpdateEndpoint added in v0.17.0 

func (c *ControllerSupport) UpdateEndpoint(endpoint *submV1.Endpoint)

func (*ControllerSupport) UpdateNode added in v0.17.0 

func (c *ControllerSupport) UpdateNode(node *corev1.Node)

type TestEndpointsOnlyHandler added in v0.18.0 

type TestEndpointsOnlyHandler struct {
	TestHandlerBase
}

func NewEndpointsOnlyHandler added in v0.18.0 

func NewEndpointsOnlyHandler(name, networkPlugin string, events chan TestEvent) *TestEndpointsOnlyHandler

type TestEvent 

type TestEvent struct {
	Name      string
	Handler   string
	Parameter interface{}
}

type TestHandler 

type TestHandler struct {
	TestHandlerBase
}

func NewTestHandler 

func NewTestHandler(name, networkPlugin string, events chan TestEvent) *TestHandler

func (*TestHandler) NodeCreated 

func (t *TestHandler) NodeCreated(node *v12.Node) error

func (*TestHandler) NodeRemoved 

func (t *TestHandler) NodeRemoved(node *v12.Node) error

func (*TestHandler) NodeUpdated 

func (t *TestHandler) NodeUpdated(node *v12.Node) error

type TestHandlerBase added in v0.18.0 

type TestHandlerBase struct {
	event.HandlerBase
	Name          string
	NetworkPlugin string
	Events        chan TestEvent
	Initialized   bool
	// contains filtered or unexported fields
}

func (*TestHandlerBase) FailOnEvent added in v0.18.0 

func (t *TestHandlerBase) FailOnEvent(eventName ...string)

func (*TestHandlerBase) GetName added in v0.18.0 

func (t *TestHandlerBase) GetName() string

func (*TestHandlerBase) GetNetworkPlugins added in v0.18.0 

func (t *TestHandlerBase) GetNetworkPlugins() []string

func (*TestHandlerBase) Init added in v0.18.0 

func (t *TestHandlerBase) Init() error

func (*TestHandlerBase) LocalEndpointCreated added in v0.18.0 

func (t *TestHandlerBase) LocalEndpointCreated(endpoint *v1.Endpoint) error

func (*TestHandlerBase) LocalEndpointRemoved added in v0.18.0 

func (t *TestHandlerBase) LocalEndpointRemoved(endpoint *v1.Endpoint) error

func (*TestHandlerBase) LocalEndpointUpdated added in v0.18.0 

func (t *TestHandlerBase) LocalEndpointUpdated(endpoint *v1.Endpoint) error

func (*TestHandlerBase) RemoteEndpointCreated added in v0.18.0 

func (t *TestHandlerBase) RemoteEndpointCreated(endpoint *v1.Endpoint) error

func (*TestHandlerBase) RemoteEndpointRemoved added in v0.18.0 

func (t *TestHandlerBase) RemoteEndpointRemoved(endpoint *v1.Endpoint) error

func (*TestHandlerBase) RemoteEndpointUpdated added in v0.18.0 

func (t *TestHandlerBase) RemoteEndpointUpdated(endpoint *v1.Endpoint) error

func (*TestHandlerBase) Stop added in v0.18.0 

func (t *TestHandlerBase) Stop() error

func (*TestHandlerBase) TransitionToGateway added in v0.18.0 

func (t *TestHandlerBase) TransitionToGateway() error

func (*TestHandlerBase) TransitionToNonGateway added in v0.18.0 

func (t *TestHandlerBase) TransitionToNonGateway() error

func (*TestHandlerBase) Uninstall added in v0.18.0 

func (t *TestHandlerBase) Uninstall() error

type TestHandlerState added in v0.17.0 

type TestHandlerState struct {
	event.DefaultHandlerState
	Gateway bool
}

func (*TestHandlerState) IsOnGateway added in v0.17.0 

func (c *TestHandlerState) IsOnGateway() bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.