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

package minion

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

Package minion provides Registry interface and implementation for storing Minions.


Package Files

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


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.Minion) 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.Minion, error)

func (*HealthyRegistry) ListMinions Uses

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

type REST Uses

type REST struct {
    // contains filtered or unexported fields

REST implements the RESTStorage interface, backed by a MinionRegistry.

func NewREST Uses

func NewREST(m Registry) *REST

NewREST returns a new REST.

func (*REST) Create Uses

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

func (*REST) Delete Uses

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

func (*REST) Get Uses

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

func (*REST) List Uses

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

func (*REST) New Uses

func (rs *REST) New() 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, minion runtime.Object) (<-chan apiserver.RESTResult, error)

type Registry Uses

type Registry interface {
    ListMinions(ctx api.Context) (*api.MinionList, error)
    CreateMinion(ctx api.Context, minion *api.Minion) error
    GetMinion(ctx api.Context, minionID string) (*api.Minion, error)
    DeleteMinion(ctx api.Context, minionID string) error

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

func NewHealthyRegistry Uses

func NewHealthyRegistry(delegate Registry, client client.KubeletHealthChecker) Registry

Package minion imports 13 packages (graph). Updated 2018-04-10. Refresh now. Tools for package owners.