minion

Apr 13, 2015

Changes in this version

+ var StatusStrategy = nodeStatusStrategy

+ func NodeToSelectableFields(node *api.Node) fields.Set

Apr 8, 2015

Changes in this version

+ var Strategy = nodeStrategy

+ func MatchNode(label labels.Selector, field fields.Selector) generic.Matcher

+ func ResourceLocation(getter ResourceGetter, connection client.ConnectionInfoGetter, ctx api.Context, ...) (*url.URL, http.RoundTripper, error)

type Registry

+ func NewRegistry(s rest.StandardStorage) Registry

+ type ResourceGetter interface

+ Get func(api.Context, string) (runtime.Object, error)

Jan 28, 2015

Changes in this version

type REST

+ func (*REST) NewList() runtime.Object

Jan 7, 2015

Changes in this version

type HealthyRegistry

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

type REST

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

type Registry

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

Nov 19, 2014

Changes in this version

type HealthyRegistry

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

type REST

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

type Registry

+ UpdateMinion func(ctx api.Context, minion *api.Minion) error

Oct 30, 2014

Changes in this version

+ var ErrDoesNotExist = fmt.Errorf("The requested resource does not exist.")

+ var ErrNotHealty = fmt.Errorf("The requested minion is not healthy.")

+ type CachingRegistry struct

+ func (r *CachingRegistry) CreateMinion(ctx api.Context, minion *api.Minion) error

+ func (r *CachingRegistry) DeleteMinion(ctx api.Context, nodeID string) error

+ func (r *CachingRegistry) GetMinion(ctx api.Context, nodeID string) (*api.Minion, error)

+ func (r *CachingRegistry) ListMinions(ctx api.Context) (*api.MinionList, error)

+ type Clock interface

+ Now func() time.Time

+ type CloudRegistry struct

+ func NewCloudRegistry(cloud cloudprovider.Interface, matchRE string, ...) (*CloudRegistry, error)

+ func (r *CloudRegistry) GetMinion(ctx api.Context, nodeID string) (*api.Minion, error)

+ func (r *CloudRegistry) ListMinions(ctx api.Context) (*api.MinionList, error)

+ func (r CloudRegistry) CreateMinion(ctx api.Context, minion *api.Minion) error

+ func (r CloudRegistry) DeleteMinion(ctx api.Context, nodeID string) error

+ type HealthyRegistry struct

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

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

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

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

+ type REST struct

+ func NewREST(m Registry) *REST

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

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

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

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

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

+ func (rs *REST) Update(ctx api.Context, minion runtime.Object) (<-chan runtime.Object, error)

+ type Registry interface

+ CreateMinion func(ctx api.Context, minion *api.Minion) error

+ DeleteMinion func(ctx api.Context, minionID string) error

+ GetMinion func(ctx api.Context, minionID string) (*api.Minion, error)

+ ListMinions func(ctx api.Context) (*api.MinionList, error)

+ func NewCachingRegistry(delegate Registry, ttl time.Duration) (Registry, error)

+ func NewHealthyRegistry(delegate Registry, client *http.Client) Registry

+ type SystemClock struct

+ func (SystemClock) Now() time.Time