endpoint

Documentation

Index

• func NewStorage(registry Registry) apiserver.RESTStorage
• type Registry
• type Storage
  • func (rs *Storage) Create(obj interface{}) (<-chan interface{}, error)
  • func (rs *Storage) Delete(id string) (<-chan interface{}, error)
  • func (rs *Storage) Get(id string) (interface{}, error)
  • func (rs *Storage) List(selector labels.Selector) (interface{}, error)
  • func (rs Storage) New() interface{}
  • func (rs *Storage) Update(obj interface{}) (<-chan interface{}, error)
  • func (rs *Storage) Watch(label, field labels.Selector, resourceVersion uint64) (watch.Interface, error)

Functions

func NewStorage

func NewStorage(registry Registry) apiserver.RESTStorage

NewStorage returns a new Storage implementation for endpoints

Types

type Registry

type Registry interface {
	GetEndpoints(name string) (*api.Endpoints, error)
	WatchEndpoints(labels, fields labels.Selector, resourceVersion uint64) (watch.Interface, error)
	UpdateEndpoints(e api.Endpoints) error
}

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

type Storage

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

Storage adapts endpoints into apiserver's RESTStorage model.

func (*Storage) Create

func (rs *Storage) Create(obj interface{}) (<-chan interface{}, error)

Create satisfies the RESTStorage interface but is unimplemented

func (*Storage) Delete

func (rs *Storage) Delete(id string) (<-chan interface{}, error)

Delete satisfies the RESTStorage interface but is unimplemented

func (*Storage) Get

func (rs *Storage) Get(id string) (interface{}, error)

Get satisfies the RESTStorage interface but is unimplemented

func (*Storage) List

func (rs *Storage) List(selector labels.Selector) (interface{}, error)

List satisfies the RESTStorage interface but is unimplemented

func (Storage) New

func (rs Storage) New() interface{}

New implements the RESTStorage interface

func (*Storage) Update

func (rs *Storage) Update(obj interface{}) (<-chan interface{}, error)

Update satisfies the RESTStorage interface but is unimplemented

func (*Storage) Watch

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

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