service

Documentation

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 service objects between the federation and member clusters in sync.

func (*ServiceController) Run

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

Run starts informers, delay deliverers and workers. Workers continuously watch for events which could be from federation or federated clusters and tries to reconcile the service objects from federation to federated clusters.