service

Documentation

Overview

Package service provides Registry interface and it's RESTStorage implementation for storing Service api objects.

Index

• func GetServiceEnvironmentVariables(registry Registry, machine string) ([]api.EnvVar, error)
• type REST
  • func NewREST(registry Registry, cloud cloudprovider.Interface, machines minion.Registry) *REST
  • func (rs *REST) Create(obj runtime.Object) (<-chan runtime.Object, error)
  • func (rs *REST) Delete(id string) (<-chan runtime.Object, error)
  • func (rs *REST) Get(id string) (runtime.Object, error)
  • func (rs *REST) List(selector labels.Selector) (runtime.Object, error)
  • func (*REST) New() runtime.Object
  • func (rs *REST) ResourceLocation(id string) (string, error)
  • func (rs *REST) Update(obj runtime.Object) (<-chan runtime.Object, error)
  • func (rs *REST) Watch(label, field labels.Selector, resourceVersion uint64) (watch.Interface, error)
• type Registry

Functions

func GetServiceEnvironmentVariables

func GetServiceEnvironmentVariables(registry Registry, machine string) ([]api.EnvVar, error)

GetServiceEnvironmentVariables populates a list of environment variables that are use in the container environment to get access to services.

Types

type REST

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

REST adapts a service registry into apiserver's RESTStorage model.

func NewREST

func NewREST(registry Registry, cloud cloudprovider.Interface, machines minion.Registry) *REST

NewREST returns a new REST.

func (*REST) Create

func (rs *REST) Create(obj runtime.Object) (<-chan runtime.Object, error)

func (*REST) Delete

func (rs *REST) Delete(id string) (<-chan runtime.Object, error)

func (*REST) Get

func (rs *REST) Get(id string) (runtime.Object, error)

func (*REST) List

func (rs *REST) List(selector labels.Selector) (runtime.Object, error)

func (*REST) New

func (*REST) New() runtime.Object

func (*REST) ResourceLocation

func (rs *REST) ResourceLocation(id string) (string, error)

ResourceLocation returns a URL to which one can send traffic for the specified service.

func (*REST) Update

func (rs *REST) Update(obj runtime.Object) (<-chan runtime.Object, error)

func (*REST) Watch

func (rs *REST) Watch(label, field labels.Selector, resourceVersion uint64) (watch.Interface, error)

Watch returns Services events via a watch.Interface. It implements apiserver.ResourceWatcher.

type Registry

type Registry interface {
	ListServices() (*api.ServiceList, error)
	CreateService(svc *api.Service) error
	GetService(name string) (*api.Service, error)
	DeleteService(name string) error
	UpdateService(svc *api.Service) error
	WatchServices(labels, fields labels.Selector, resourceVersion uint64) (watch.Interface, error)

	// TODO: endpoints and their implementation should be separated, setting endpoints should be
	// supported via the API, and the endpoints-controller should use the API to update endpoints.
	endpoint.Registry
}

Registry is an interface for things that know how to store services.