ovn

Documentation

Index

• Constants
• Variables
• func NewSyncHandler(k8sClientset clientset.Interface, env environment.Specification) 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.254.9"  // public constant, used in the route-agent handler
	HostUpstreamIP             = "169.254.254.10" // we configure this one as ovn-k8s-sub0 interface on each worker node
	HostUpstreamNET            = HostUpstreamIP + "/29"
	SubmarinerUpstreamLocalnet = "submariner_gateway"
)

Variables

var ErrWaitingForLocalEndpoint = 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, env environment.Specification) 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