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

package pod

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

Package pod provides Registry interface and it's RESTStorage implementation for storing Pod api objects.


Package Files

bound_pod_factory.go doc.go registry.go rest.go

type BasicBoundPodFactory Uses

type BasicBoundPodFactory struct {
    // TODO: this should really point at the API rather than a registry
    ServiceRegistry service.Registry

func (*BasicBoundPodFactory) MakeBoundPod Uses

func (b *BasicBoundPodFactory) MakeBoundPod(machine string, pod *api.Pod) (*api.BoundPod, error)

type BoundPodFactory Uses

type BoundPodFactory interface {
    // Make a container object for a given pod, given the machine that the pod is running on.
    MakeBoundPod(machine string, pod *api.Pod) (*api.BoundPod, error)

type REST Uses

type REST struct {
    // contains filtered or unexported fields

REST implements the RESTStorage interface in terms of a PodRegistry.

func NewREST Uses

func NewREST(config *RESTConfig) *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 (*REST) New() runtime.Object

func (*REST) Update Uses

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

func (*REST) Watch Uses

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

Watch begins watching for new, changed, or deleted pods.

type RESTConfig Uses

type RESTConfig struct {
    CloudProvider cloudprovider.Interface
    PodCache      client.PodInfoGetter
    PodInfoGetter client.PodInfoGetter
    Registry      Registry
    Minions       client.MinionInterface

type Registry Uses

type Registry interface {
    // ListPods obtains a list of pods having labels which match selector.
    ListPods(ctx api.Context, selector labels.Selector) (*api.PodList, error)
    // ListPodsPredicate obtains a list of pods for which filter returns true.
    ListPodsPredicate(ctx api.Context, filter func(*api.Pod) bool) (*api.PodList, error)
    // Watch for new/changed/deleted pods
    WatchPods(ctx api.Context, resourceVersion string, filter func(*api.Pod) bool) (watch.Interface, error)
    // Get a specific pod
    GetPod(ctx api.Context, podID string) (*api.Pod, error)
    // Create a pod based on a specification.
    CreatePod(ctx api.Context, pod *api.Pod) error
    // Update an existing pod
    UpdatePod(ctx api.Context, pod *api.Pod) error
    // Delete an existing pod
    DeletePod(ctx api.Context, podID string) error

Registry is an interface implemented by things that know how to store Pod objects.

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