ovn

package
v0.19.0-rc2 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	IPTCPOverHead         = 40
	ExpectedIPSECOverhead = 62
	MSSFor1500MTU         = 1500 - IPTCPOverHead - ExpectedIPSECOverhead
)
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()

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
	TransitSwitchIP TransitSwitchIPGetter
}

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,
	namespace string, transitSwitchIP TransitSwitchIPGetter,
) (*NonGatewayRouteController, error)

type NonGatewayRouteHandler added in v0.16.0 

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

func NewNonGatewayRouteHandler added in v0.16.0 

func NewNonGatewayRouteHandler(smClient submarinerClientset.Interface, k8sClient kubernetes.Interface, transitSwitchIP TransitSwitchIP,
) *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) NodeUpdated added in v0.19.0 

func (h *NonGatewayRouteHandler) NodeUpdated(node *corev1.Node) 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

type TransitSwitchIP added in v0.19.0 

type TransitSwitchIP interface {
	TransitSwitchIPGetter
	Init(k8sClient kubernetes.Interface) error
	UpdateFrom(node *corev1.Node) (bool, error)
}

func NewTransitSwitchIP added in v0.19.0 

func NewTransitSwitchIP() TransitSwitchIP

type TransitSwitchIPGetter added in v0.19.0 

type TransitSwitchIPGetter interface {
	Get() string
}

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.