services

Documentation

Index

• func IsLocalOnly(service *v1.Service) bool
• type LocalService
• type Server
  • func NewServiceServer(vpp *vpplink.VppLink, k8sclient *kubernetes.Clientset, log *logrus.Entry) *Server
  • func (s *Server) GetLocalService(service *v1.Service, ep *v1.Endpoints) (localService *LocalService)
  • func (s *Server) ServeService(t *tomb.Tomb) error
  • func (s *Server) SetBGPConf(bgpConf *calicov3.BGPConfigurationSpec)
  • func (s *Server) SetOurBGPSpec(nodeBGPSpec *common.LocalNodeSpec)
• type ServiceState

Functions

func IsLocalOnly

func IsLocalOnly(service *v1.Service) bool

Types

type LocalService

type LocalService struct {
	Entries        []types.CnatTranslateEntry
	SpecificRoutes []net.IP
	ServiceID      string
}

*

• Service descriptions from the API are resolved into
• slices of LocalService, this allows to diffs between
• previous & expected state in VPP

type Server

type Server struct {
	BGPConf *calicov3.BGPConfigurationSpec
	// contains filtered or unexported fields
}

func NewServiceServer

func NewServiceServer(vpp *vpplink.VppLink, k8sclient *kubernetes.Clientset, log *logrus.Entry) *Server

func (*Server) GetLocalService

func (s *Server) GetLocalService(service *v1.Service, ep *v1.Endpoints) (localService *LocalService)

func (*Server) ServeService

func (s *Server) ServeService(t *tomb.Tomb) error

func (*Server) SetBGPConf

func (s *Server) SetBGPConf(bgpConf *calicov3.BGPConfigurationSpec)

func (*Server) SetOurBGPSpec

func (s *Server) SetOurBGPSpec(nodeBGPSpec *common.LocalNodeSpec)

type ServiceState

type ServiceState struct {
	OwnerServiceID string /* serviceID(service.ObjectMeta) of the service that created this entry */
	VppID          uint32 /* cnat translation ID in VPP */
}

*

• Store VPP's state in a map [CnatTranslateEntry.Key()]->ServiceState