ovn

Documentation

Index

• Constants
• Variables
• func NewSyncHandler(k8sClientset clientset.Interface) event.Handler
• type SyncHandler
  • func (ovn *SyncHandler) GetName() string
  • func (ovn *SyncHandler) GetNetworkPlugins() []string
  • func (ovn *SyncHandler) Init() error
  • func (ovn *SyncHandler) LocalEndpointCreated(endpoint *submV1.Endpoint) error
  • func (ovn *SyncHandler) LocalEndpointRemoved(endpoint *submV1.Endpoint) error
  • func (ovn *SyncHandler) LocalEndpointUpdated(endpoint *submV1.Endpoint) error
  • func (ovn *SyncHandler) RemoteEndpointCreated(endpoint *submV1.Endpoint) error
  • func (ovn *SyncHandler) RemoteEndpointRemoved(endpoint *submV1.Endpoint) error
  • func (ovn *SyncHandler) RemoteEndpointUpdated(endpoint *submV1.Endpoint) error

Constants

const (
	SubmarinerUpstreamIP = "169.254.33.7" // public constant, used in the route-agent handler

)

Variables

var WaitingForLocalEndpoint = errors.New("Waiting for the local endpoint details before we can " +
	"setup any remote endpoint related information, this will be retried.")

Functions

func NewSyncHandler

func NewSyncHandler(k8sClientset clientset.Interface) event.Handler

Types

type SyncHandler

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

func (*SyncHandler) GetName

func (ovn *SyncHandler) GetName() string

func (*SyncHandler) GetNetworkPlugins

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

func (*SyncHandler) Init

func (ovn *SyncHandler) Init() error

func (*SyncHandler) LocalEndpointCreated

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

func (*SyncHandler) LocalEndpointRemoved

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

func (*SyncHandler) LocalEndpointUpdated

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

func (*SyncHandler) RemoteEndpointCreated

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

func (*SyncHandler) RemoteEndpointRemoved

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

func (*SyncHandler) RemoteEndpointUpdated

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