package service

import "k8s.io/kubernetes/federation/pkg/federation-controller/service"

Index ¶

• Constants
• Variables
• func Equivalent(s1, s2 *v1.Service) bool
• type ServiceController
• func New(federationClient fedclientset.Interface) *ServiceController
• func (s *ServiceController) Run(workers int, stopCh <-chan struct{})

Constants ¶

const (
	UserAgentName = "federation-service-controller"

	ControllerName = "services"
)

Variables ¶

var (
	RequiredResources = []schema.GroupVersionResource{v1.SchemeGroupVersion.WithResource("services")}
)

Functions ¶

func Equivalent ¶

func Equivalent(s1, s2 *v1.Service) bool

Equivalent Checks if cluster-independent, user provided data in two given services are equal. If in the future the services structure is expanded then any field that is not populated by the api server should be included here.

Types ¶

type ServiceController ¶

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

func New ¶

func New(federationClient fedclientset.Interface) *ServiceController

New returns a new service controller to keep DNS provider service resources (like Kubernetes Services and DNS server records for service discovery) in sync with the registry.

func (*ServiceController) Run ¶

func (s *ServiceController) Run(workers int, stopCh <-chan struct{})

It's an error to call Run() more than once for a given ServiceController object.

Source Files ¶

servicecontroller.go

Directories ¶