kubeproxy

Documentation

Index

• Constants
• type Operation
• type SyncHandler
  • func NewSyncHandler(localClusterCidr, localServiceCidr []string) *SyncHandler
  • func (kp *SyncHandler) GetName() string
  • func (kp *SyncHandler) GetNetworkPlugins() []string
  • func (kp *SyncHandler) Init(_ context.Context) error
  • func (kp *SyncHandler) LocalEndpointCreated(endpoint *submV1.Endpoint) error
  • func (kp *SyncHandler) LocalEndpointRemoved(endpoint *submV1.Endpoint) error
  • func (kp *SyncHandler) NodeCreated(node *k8sV1.Node) error
  • func (kp *SyncHandler) NodeRemoved(node *k8sV1.Node) error
  • func (kp *SyncHandler) RemoteEndpointCreated(endpoint *submV1.Endpoint) error
  • func (kp *SyncHandler) RemoteEndpointRemoved(endpoint *submV1.Endpoint) error
  • func (kp *SyncHandler) TransitionToGateway() error
  • func (kp *SyncHandler) TransitionToNonGateway() error
  • func (kp *SyncHandler) Uninstall() error

Constants

const (
	VxLANIface         = "vx-submariner"
	VxInterfaceWorker  = 0
	VxInterfaceGateway = 1

	VxLANVTepNetworkPrefix = 240
	SmRouteAgentFilter     = "app=submariner-routeagent"
)

Types

type Operation

type Operation int

const (
	Add Operation = iota
	Delete
	Flush
)

type SyncHandler

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

func NewSyncHandler

func NewSyncHandler(localClusterCidr, localServiceCidr []string) *SyncHandler

func (*SyncHandler) GetName

func (kp *SyncHandler) GetName() string

func (*SyncHandler) GetNetworkPlugins

func (kp *SyncHandler) GetNetworkPlugins() []string

func (*SyncHandler) Init

func (kp *SyncHandler) Init(_ context.Context) error

func (*SyncHandler) LocalEndpointCreated

func (kp *SyncHandler) LocalEndpointCreated(endpoint *submV1.Endpoint) error

func (*SyncHandler) LocalEndpointRemoved

func (kp *SyncHandler) LocalEndpointRemoved(endpoint *submV1.Endpoint) error

func (*SyncHandler) NodeCreated

func (kp *SyncHandler) NodeCreated(node *k8sV1.Node) error

func (*SyncHandler) NodeRemoved

func (kp *SyncHandler) NodeRemoved(node *k8sV1.Node) error

func (*SyncHandler) RemoteEndpointCreated

func (kp *SyncHandler) RemoteEndpointCreated(endpoint *submV1.Endpoint) error

func (*SyncHandler) RemoteEndpointRemoved

func (kp *SyncHandler) RemoteEndpointRemoved(endpoint *submV1.Endpoint) error

func (*SyncHandler) TransitionToGateway

func (kp *SyncHandler) TransitionToGateway() error

func (*SyncHandler) TransitionToNonGateway

func (kp *SyncHandler) TransitionToNonGateway() error

func (*SyncHandler) Uninstall

func (kp *SyncHandler) Uninstall() error