storage

Documentation

Index

• type BindingREST
  • func (r *BindingREST) Create(ctx context.Context, obj runtime.Object, ...) (out runtime.Object, err error)
  • func (r *BindingREST) NamespaceScoped() bool
  • func (r *BindingREST) New() runtime.Object
• type EventREST
  • func (r *EventREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
  • func (r *EventREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind
  • func (r *EventREST) New() runtime.Object
• type ExecREST
  • func (r *ExecREST) Connect(ctx context.Context, name string, opts runtime.Object, ...) (http.Handler, error)
  • func (r *ExecREST) ConnectMethods() []string
  • func (r *ExecREST) New() runtime.Object
  • func (r *ExecREST) NewConnectOptions() (runtime.Object, bool, string)
• type LogREST
  • func (r *LogREST) Get(ctx context.Context, name string, opts runtime.Object) (runtime.Object, error)
  • func (r *LogREST) New() runtime.Object
  • func (r *LogREST) NewGetOptions() (runtime.Object, bool, string)
  • func (r *LogREST) OverrideMetricsVerb(oldVerb string) (newVerb string)
  • func (r *LogREST) ProducesMIMETypes(verb string) []string
  • func (r *LogREST) ProducesObject(verb string) interface{}
• type REST
  • func (r *REST) Categories() []string
  • func (r *REST) ShortNames() []string
• type StatusREST
  • func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
  • func (r *StatusREST) New() runtime.Object
  • func (r *StatusREST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, ...) (runtime.Object, bool, error)
• type Storage
  • func NewStorage(_ genericregistry.RESTOptionsGetter, ...) *Storage

Types

type BindingREST

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

BindingREST implements the REST endpoint for binding pods to nodes when etcd is in use.

func (*BindingREST) Create

func (r *BindingREST) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (out runtime.Object, err error)

Create ensures a pod is bound to a specific host.

func (*BindingREST) NamespaceScoped

func (r *BindingREST) NamespaceScoped() bool

NamespaceScoped fulfill rest.Scoper

func (*BindingREST) New

func (r *BindingREST) New() runtime.Object

New creates a new binding resource

type EventREST

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

EventREST implements the REST endpoint for find events by a daemonset.

func (*EventREST) Get

func (r *EventREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)

Get retrieves the object from the storage. It is required to support Patch.

func (*EventREST) GroupVersionKind

func (r *EventREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind

GroupVersionKind is used to specify a particular GroupVersionKind to discovery.

func (*EventREST) New

func (r *EventREST) New() runtime.Object

New returns an empty object that can be used with Create and Update after request data has been put into it.

type ExecREST

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

ExecREST implements the exec endpoint for a Pod

func (*ExecREST) Connect

func (r *ExecREST) Connect(ctx context.Context, name string, opts runtime.Object, responder rest.Responder) (http.Handler, error)

Connect returns a handler for the pod exec proxy

func (*ExecREST) ConnectMethods

func (r *ExecREST) ConnectMethods() []string

ConnectMethods returns the methods supported by exec

func (*ExecREST) New

func (r *ExecREST) New() runtime.Object

New creates a new Pod log options object

func (*ExecREST) NewConnectOptions

func (r *ExecREST) NewConnectOptions() (runtime.Object, bool, string)

NewConnectOptions returns versioned resource that represents proxy parameters

type LogREST

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

LogREST implements the log endpoint for a Pod

func (*LogREST) Get

func (r *LogREST) Get(ctx context.Context, name string, opts runtime.Object) (runtime.Object, error)

Get retrieves a runtime.Object that will stream the contents of the pod log

func (*LogREST) New

func (r *LogREST) New() runtime.Object

New creates a new Pod log options object

func (*LogREST) NewGetOptions

func (r *LogREST) NewGetOptions() (runtime.Object, bool, string)

NewGetOptions returns versioned resource that represents proxy parameters

func (*LogREST) OverrideMetricsVerb

func (r *LogREST) OverrideMetricsVerb(oldVerb string) (newVerb string)

OverrideMetricsVerb override the GET verb to CONNECT for pod log resource

func (*LogREST) ProducesMIMETypes

func (r *LogREST) ProducesMIMETypes(verb string) []string

ProducesMIMETypes implements StorageMetadata

func (*LogREST) ProducesObject

func (r *LogREST) ProducesObject(verb string) interface{}

ProducesObject implements StorageMetadata, return string as the generating object

type REST

type REST struct {
	*proxy.Store
}

REST implements pkg/api/rest.StandardStorage.

func (*REST) Categories

func (r *REST) Categories() []string

Categories implements the CategoriesProvider interface. Returns a list of categories a resource is part of.

func (*REST) ShortNames

func (r *REST) ShortNames() []string

ShortNames implements the ShortNamesProvider interface. Returns a list of short names for a resource.

type StatusREST

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

StatusREST implements the REST endpoint for changing the status of a pod.

func (*StatusREST) Get

func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)

Get retrieves the object from the storage. It is required to support Patch.

func (*StatusREST) New

func (r *StatusREST) New() runtime.Object

New creates a new pod resource

func (*StatusREST) Update

func (r *StatusREST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc, forceAllowCreate bool, options *metav1.UpdateOptions) (runtime.Object, bool, error)

Update alters the status subset of an object.

type Storage

type Storage struct {
	Pod     *REST
	Status  *StatusREST
	Binding *BindingREST
	Events  *EventREST
	Log     *LogREST
	Exec    *ExecREST
}

Storage includes storage for resources.

func NewStorage

func NewStorage(_ genericregistry.RESTOptionsGetter, platformClient platforminternalclient.PlatformInterface) *Storage

NewStorage returns a Storage object that will work against resources.