package service

import "k8s.io/kubernetes/pkg/registry/core/service"

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

Index ¶

• Variables
• type ProxyREST
• func (r *ProxyREST) Connect(ctx genericapirequest.Context, id string, opts runtime.Object, responder rest.Responder) (http.Handler, error)
• func (r *ProxyREST) ConnectMethods() []string
• func (r *ProxyREST) New() runtime.Object
• func (r *ProxyREST) NewConnectOptions() (runtime.Object, bool, string)
• type Registry
• func NewRegistry(s rest.StandardStorage) Registry

Variables ¶

var StatusStrategy = serviceStatusStrategy{Strategy}

StatusStrategy is the default logic invoked when updating service status.

var Strategy = svcStrategy{legacyscheme.Scheme, names.SimpleNameGenerator}

Services is the default logic that applies when creating and updating Service objects.

Types ¶

type ProxyREST ¶

type ProxyREST struct {
	Redirector     rest.Redirector
	ProxyTransport http.RoundTripper
}

ProxyREST implements the proxy subresource for a Service

func (*ProxyREST) Connect ¶

func (r *ProxyREST) Connect(ctx genericapirequest.Context, id string, opts runtime.Object, responder rest.Responder) (http.Handler, error)

Connect returns a handler for the service proxy

func (*ProxyREST) ConnectMethods ¶

func (r *ProxyREST) ConnectMethods() []string

ConnectMethods returns the list of HTTP methods that can be proxied

func (*ProxyREST) New ¶

func (r *ProxyREST) New() runtime.Object

New returns an empty service resource

func (*ProxyREST) NewConnectOptions ¶

func (r *ProxyREST) NewConnectOptions() (runtime.Object, bool, string)

NewConnectOptions returns versioned resource that represents proxy parameters

type Registry ¶

type Registry interface {
	ListServices(ctx genericapirequest.Context, options *metainternalversion.ListOptions) (*api.ServiceList, error)
	CreateService(ctx genericapirequest.Context, svc *api.Service, createValidation rest.ValidateObjectFunc) (*api.Service, error)
	GetService(ctx genericapirequest.Context, name string, options *metav1.GetOptions) (*api.Service, error)
	DeleteService(ctx genericapirequest.Context, name string) error
	UpdateService(ctx genericapirequest.Context, svc *api.Service, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc) (*api.Service, error)
	WatchServices(ctx genericapirequest.Context, options *metainternalversion.ListOptions) (watch.Interface, error)
	ExportService(ctx genericapirequest.Context, name string, options metav1.ExportOptions) (*api.Service, error)
}

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

func NewRegistry ¶

func NewRegistry(s rest.StandardStorage) Registry

NewRegistry returns a new Registry interface for the given Storage. Any mismatched types will panic.

Source Files ¶

doc.go proxy.go registry.go strategy.go

Directories ¶