service

package

v0.15.1-0...-23e8066 Latest Latest Go to latest Published: Apr 20, 2015 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/spacejam/kubernetes

Documentation ¶

Overview ¶

Package service provides the Registry interface and its RESTStorage implementation for storing Service api objects.

Index ¶

func GetIndexedIP(subnet *net.IPNet, index int) (net.IP, error)
type REST
- func NewStorage(registry Registry, machines minion.Registry, endpoints endpoint.Registry, ...) *REST
type Registry

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetIndexedIP ¶

func GetIndexedIP(subnet *net.IPNet, index int) (net.IP, error)

Returns the index-th IP from the specified subnet range. For example, subnet "10.0.0.0/24" with index "2" will return the IP "10.0.0.2". TODO(saad-ali): Move this (and any other functions that are independent of ipAllocator) to some place more generic.

Types ¶

type REST ¶

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

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

func NewStorage ¶

func NewStorage(registry Registry, machines minion.Registry, endpoints endpoint.Registry, portalNet *net.IPNet,
	clusterName string) *REST

NewStorage returns a new REST.

func (*REST) Create ¶

func (rs *REST) Create(ctx api.Context, obj runtime.Object) (runtime.Object, error)

func (*REST) Delete ¶

func (rs *REST) Delete(ctx api.Context, id string) (runtime.Object, error)

func (*REST) Get ¶

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

func (*REST) List ¶

func (rs *REST) List(ctx api.Context, label labels.Selector, field fields.Selector) (runtime.Object, error)

func (*REST) New ¶

func (*REST) New() runtime.Object

func (*REST) NewList ¶

func (*REST) NewList() runtime.Object

func (*REST) ResourceLocation ¶

func (rs *REST) ResourceLocation(ctx api.Context, id string) (*url.URL, http.RoundTripper, error)

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

func (*REST) Update ¶

func (rs *REST) Update(ctx api.Context, obj runtime.Object) (runtime.Object, bool, error)

func (*REST) Watch ¶

func (rs *REST) Watch(ctx api.Context, label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

Watch returns Services events via a watch.Interface. It implements rest.Watcher.

type Registry ¶

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

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL