kubernetes: github.com/janzhou/kubernetes/pkg/registry/minion Index | Files

package minion

import "github.com/janzhou/kubernetes/pkg/registry/minion"

Package minion provides Registry interface and implementation for storing Minions.

Index

Package Files

doc.go healthy_registry.go registry.go rest.go

Variables

var ErrDoesNotExist = errors.New("The requested resource does not exist.")
var ErrNotHealty = errors.New("The requested minion is not healthy.")

type HealthyRegistry Uses

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

func (*HealthyRegistry) CreateMinion Uses

func (r *HealthyRegistry) CreateMinion(ctx api.Context, minion *api.Node) error

func (*HealthyRegistry) DeleteMinion Uses

func (r *HealthyRegistry) DeleteMinion(ctx api.Context, minionID string) error

func (*HealthyRegistry) GetMinion Uses

func (r *HealthyRegistry) GetMinion(ctx api.Context, minionID string) (*api.Node, error)

func (*HealthyRegistry) ListMinions Uses

func (r *HealthyRegistry) ListMinions(ctx api.Context) (currentMinions *api.NodeList, err error)

func (*HealthyRegistry) UpdateMinion Uses

func (r *HealthyRegistry) UpdateMinion(ctx api.Context, minion *api.Node) error

func (*HealthyRegistry) WatchMinions Uses

func (r *HealthyRegistry) WatchMinions(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

type REST Uses

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

REST adapts minion into apiserver's RESTStorage model.

func NewREST Uses

func NewREST(m Registry) *REST

NewREST returns a new apiserver.RESTStorage implementation for minion.

func (*REST) Create Uses

func (rs *REST) Create(ctx api.Context, obj runtime.Object) (<-chan apiserver.RESTResult, error)

Create satisfies the RESTStorage interface.

func (*REST) Delete Uses

func (rs *REST) Delete(ctx api.Context, id string) (<-chan apiserver.RESTResult, error)

Delete satisfies the RESTStorage interface.

func (*REST) Get Uses

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

Get satisfies the RESTStorage interface.

func (*REST) List Uses

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

List satisfies the RESTStorage interface.

func (*REST) New Uses

func (rs *REST) New() runtime.Object

func (*REST) NewList Uses

func (*REST) NewList() runtime.Object

func (*REST) ResourceLocation Uses

func (rs *REST) ResourceLocation(ctx api.Context, id string) (string, error)

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

func (*REST) Update Uses

func (rs *REST) Update(ctx api.Context, obj runtime.Object) (<-chan apiserver.RESTResult, error)

Update satisfies the RESTStorage interface.

func (*REST) Watch Uses

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

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

type Registry Uses

type Registry interface {
    ListMinions(ctx api.Context) (*api.NodeList, error)
    CreateMinion(ctx api.Context, minion *api.Node) error
    UpdateMinion(ctx api.Context, minion *api.Node) error
    GetMinion(ctx api.Context, minionID string) (*api.Node, error)
    DeleteMinion(ctx api.Context, minionID string) error
    WatchMinions(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)
}

MinionRegistry is an interface for things that know how to store minions.

func NewHealthyRegistry Uses

func NewHealthyRegistry(delegate Registry, client client.KubeletHealthChecker, clock util.Clock, ttl time.Duration) Registry

Package minion imports 18 packages (graph). Updated 2017-05-24. Refresh now. Tools for package owners.