ovn

package
v0.17.1 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 53 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 (
	ForwardingSubmarinerMSSClampChain = "SUBMARINER-FWD-MSSCLAMP"
	ForwardingSubmarinerFWDChain      = "SUBMARINER-FORWARD"
)
View Source 
const (
	OVNClusterRouter = "ovn_cluster_router"
)
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)

func GatewayResourceInterface added in v0.17.0 

func GatewayResourceInterface(smClient submarinerClientset.Interface, namespace string) resource.Interface[*submarinerv1.GatewayRoute]

func NonGatewayResourceInterface added in v0.17.0 

func NonGatewayResourceInterface(smClient submarinerClientset.Interface, namespace string,
) resource.Interface[*submarinerv1.NonGatewayRoute]

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(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

type Handler 

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

func NewHandler 

func NewHandler(config *HandlerConfig) *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) 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() error

func (*Handler) TransitionToGateway 

func (ovn *Handler) TransitionToGateway() error

func (*Handler) TransitionToNonGateway 

func (ovn *Handler) TransitionToNonGateway() error

func (*Handler) Uninstall added in v0.17.0 

func (ovn *Handler) Uninstall() error

type HandlerConfig added in v0.17.0 

type HandlerConfig struct {
	Namespace      string
	ClusterCIDR    []string
	ServiceCIDR    []string
	SubmClient     clientset.Interface
	K8sClient      kubernetes.Interface
	DynClient      dynamic.Interface
	WatcherConfig  *watcher.Config
	NewOVSDBClient NewOVSDBClientFn
}

type NewOVSDBClientFn added in v0.17.0 

type NewOVSDBClientFn func(_ model.ClientDBModel, _ ...libovsdbclient.Option) (libovsdbclient.Client, 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(smClient submarinerClientset.Interface, k8sClient clientset.Interface) *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

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.