ovn

package
v0.16.7 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	IPTCPOverHead         = 40
	ExpectedIPSECOverhead = 62
	MSSFor1500MTU         = 1500 - IPTCPOverHead - ExpectedIPSECOverhead
)

TODO: if the #1022 workaround needs to be sustained for some time, instead of this we should be calculating the PMTU with a tool like tracepath between the gateway endpoints, reporting back so we can use such information here.

View Source 
const (
	OVNK8sMgmntIntfName = "ovn-k8s-mp0"
)

Variables

This section is empty.

Functions

func FindOpenshiftNetwork added in v0.16.0 

func FindOpenshiftNetwork(ctx context.Context, dynamicClient dynamic.Interface) (*unstructured.Unstructured, error)

func FindPod added in v0.16.0 

func FindPod(ctx context.Context, k8sClientset clientset.Interface, labelSelector string) (*corev1.Pod, error)

Types

type ConnectionHandler added in v0.16.0 

type ConnectionHandler struct {
	// contains filtered or unexported fields
}

func NewConnectionHandler added in v0.16.0 

func NewConnectionHandler(k8sClientset clientset.Interface, dynamicClient dynamic.Interface) *ConnectionHandler

type GatewayRouteController added in v0.16.0 

type GatewayRouteController struct {
	// contains filtered or unexported fields
}

func NewGatewayRouteController added in v0.16.0 

func NewGatewayRouteController(config watcher.Config, connectionHandler *ConnectionHandler,
	namespace string,
) (*GatewayRouteController, error)

type GatewayRouteHandler added in v0.16.0 

type GatewayRouteHandler struct {
	event.HandlerBase
	// contains filtered or unexported fields
}

func NewGatewayRouteHandler added in v0.16.0 

func NewGatewayRouteHandler(env *environment.Specification, smClientSet submarinerClientset.Interface) *GatewayRouteHandler

func (*GatewayRouteHandler) GetName added in v0.16.0 

func (h *GatewayRouteHandler) GetName() string

func (*GatewayRouteHandler) GetNetworkPlugins added in v0.16.0 

func (h *GatewayRouteHandler) GetNetworkPlugins() []string

func (*GatewayRouteHandler) Init added in v0.16.0 

func (h *GatewayRouteHandler) Init() error

func (*GatewayRouteHandler) RemoteEndpointCreated added in v0.16.0 

func (h *GatewayRouteHandler) RemoteEndpointCreated(endpoint *submarinerv1.Endpoint) error

func (*GatewayRouteHandler) RemoteEndpointRemoved added in v0.16.0 

func (h *GatewayRouteHandler) RemoteEndpointRemoved(endpoint *submarinerv1.Endpoint) error

func (*GatewayRouteHandler) TransitionToGateway added in v0.16.0 

func (h *GatewayRouteHandler) TransitionToGateway() error

func (*GatewayRouteHandler) TransitionToNonGateway added in v0.16.0 

func (h *GatewayRouteHandler) TransitionToNonGateway() error

type Handler 

type Handler struct {
	event.HandlerBase
	// contains filtered or unexported fields
}

func NewHandler 

func NewHandler(env *environment.Specification, smClientSet clientset.Interface, k8sClientset *kubernetes.Clientset,
	dynamicClient dynamic.Interface, watcherConfig *watcher.Config,
) *Handler

func (*Handler) GetName 

func (ovn *Handler) GetName() string

func (*Handler) GetNetworkPlugins 

func (ovn *Handler) GetNetworkPlugins() []string

func (*Handler) Init 

func (ovn *Handler) Init() error

func (*Handler) LegacyCleanup added in v0.16.0 

func (ovn *Handler) LegacyCleanup()

TODO need to be removed when the clusters are fully upgraded to new implementation.

func (*Handler) LocalEndpointCreated 

func (ovn *Handler) LocalEndpointCreated(endpoint *submV1.Endpoint) error

func (*Handler) LocalEndpointRemoved 

func (ovn *Handler) LocalEndpointRemoved(endpoint *submV1.Endpoint) error

func (*Handler) LocalEndpointUpdated 

func (ovn *Handler) LocalEndpointUpdated(endpoint *submV1.Endpoint) error

func (*Handler) RemoteEndpointCreated 

func (ovn *Handler) RemoteEndpointCreated(endpoint *submV1.Endpoint) error

func (*Handler) RemoteEndpointRemoved 

func (ovn *Handler) RemoteEndpointRemoved(endpoint *submV1.Endpoint) error

func (*Handler) RemoteEndpointUpdated 

func (ovn *Handler) RemoteEndpointUpdated(endpoint *submV1.Endpoint) error

func (*Handler) Stop added in v0.13.0 

func (ovn *Handler) Stop(uninstall bool) error

func (*Handler) TransitionToGateway 

func (ovn *Handler) TransitionToGateway() error

func (*Handler) TransitionToNonGateway 

func (ovn *Handler) TransitionToNonGateway() error

type NonGatewayRouteController added in v0.16.0 

type NonGatewayRouteController struct {
	// contains filtered or unexported fields
}

func NewNonGatewayRouteController added in v0.16.0 

func NewNonGatewayRouteController(config watcher.Config, connectionHandler *ConnectionHandler,
	k8sClientSet clientset.Interface, namespace string,
) (*NonGatewayRouteController, error)

type NonGatewayRouteHandler added in v0.16.0 

type NonGatewayRouteHandler struct {
	event.HandlerBase
	// contains filtered or unexported fields
}

func NewNonGatewayRouteHandler added in v0.16.0 

func NewNonGatewayRouteHandler(smClientSet submarinerClientset.Interface, k8sClientset *clientset.Clientset) *NonGatewayRouteHandler

func (*NonGatewayRouteHandler) GetName added in v0.16.0 

func (h *NonGatewayRouteHandler) GetName() string

func (*NonGatewayRouteHandler) GetNetworkPlugins added in v0.16.0 

func (h *NonGatewayRouteHandler) GetNetworkPlugins() []string

func (*NonGatewayRouteHandler) Init added in v0.16.0 

func (h *NonGatewayRouteHandler) Init() error

func (*NonGatewayRouteHandler) RemoteEndpointCreated added in v0.16.0 

func (h *NonGatewayRouteHandler) RemoteEndpointCreated(endpoint *submarinerv1.Endpoint) error

func (*NonGatewayRouteHandler) RemoteEndpointRemoved added in v0.16.0 

func (h *NonGatewayRouteHandler) RemoteEndpointRemoved(endpoint *submarinerv1.Endpoint) error

func (*NonGatewayRouteHandler) TransitionToGateway added in v0.16.0 

func (h *NonGatewayRouteHandler) TransitionToGateway() error

func (*NonGatewayRouteHandler) TransitionToNonGateway added in v0.16.0 

func (h *NonGatewayRouteHandler) TransitionToNonGateway() error

Source Files

View all Source files

Directories

Path Synopsis

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.