proxy

Documentation

Overview

Package proxy contains the OpenShift SDN code that runs as part of the service proxy

Index

• func New(pluginName string, osClient *osclient.Client, kClient kclientset.Interface) (sdn.ProxyInterface, error)
• type EndpointsConfigHandler
• type OsdnProxy
  • func (proxy *OsdnProxy) OnEndpointsAdd(ep *kapi.Endpoints)
  • func (proxy *OsdnProxy) OnEndpointsDelete(ep *kapi.Endpoints)
  • func (proxy *OsdnProxy) OnEndpointsSynced()
  • func (proxy *OsdnProxy) OnEndpointsUpdate(old, ep *kapi.Endpoints)
  • func (proxy *OsdnProxy) Start(baseHandler pconfig.EndpointsHandler) error

Functions

func New

func New(pluginName string, osClient *osclient.Client, kClient kclientset.Interface) (sdn.ProxyInterface, error)

Called by higher layers to create the proxy plugin instance; only used by nodes

Types

type EndpointsConfigHandler

type EndpointsConfigHandler interface {
	// OnEndpointsUpdate gets called when endpoints configuration is changed for a given
	// service on any of the configuration sources. An example is when a new
	// service comes up, or when containers come up or down for an existing service.
	OnEndpointsUpdate(endpoints []*kapi.Endpoints)
}

EndpointsConfigHandler is an abstract interface of objects which receive update notifications for the set of endpoints.

type OsdnProxy

type OsdnProxy struct {
	// contains filtered or unexported fields
}

func (*OsdnProxy) OnEndpointsAdd

func (proxy *OsdnProxy) OnEndpointsAdd(ep *kapi.Endpoints)

func (*OsdnProxy) OnEndpointsDelete

func (proxy *OsdnProxy) OnEndpointsDelete(ep *kapi.Endpoints)

func (*OsdnProxy) OnEndpointsSynced

func (proxy *OsdnProxy) OnEndpointsSynced()

func (*OsdnProxy) OnEndpointsUpdate

func (proxy *OsdnProxy) OnEndpointsUpdate(old, ep *kapi.Endpoints)

func (*OsdnProxy) Start

func (proxy *OsdnProxy) Start(baseHandler pconfig.EndpointsHandler) error