registry

package
v0.18.1-beta.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 26, 2020 License: Apache-2.0 Imports: 34 Imported by: 3,241

Documentation

Overview

Package etcd has a generic implementation of a registry that stores things in etcd.

Index

Constants

View Source 
const (
	OptimisticLockErrorMsg = "the object has been modified; please apply your changes to the latest version and try again"
)

Variables

This section is empty.

Functions

func CleanupStorage 

func CleanupStorage()

func NamespaceKeyFunc 

func NamespaceKeyFunc(ctx context.Context, prefix string, name string) (string, error)

NamespaceKeyFunc is the default function for constructing storage paths to a resource relative to the given prefix enforcing namespace rules. If the context does not contain a namespace, it errors.

func NamespaceKeyRootFunc 

func NamespaceKeyRootFunc(ctx context.Context, prefix string) string

NamespaceKeyRootFunc is the default function for constructing storage paths to resource directories enforcing namespace rules.

func NoNamespaceKeyFunc 

func NoNamespaceKeyFunc(ctx context.Context, prefix string, name string) (string, error)

NoNamespaceKeyFunc is the default function for constructing storage paths to a resource relative to the given prefix without a namespace.

func RegisterStorageCleanup 

func RegisterStorageCleanup(fn func())

func ShouldDeleteDuringUpdate 

func ShouldDeleteDuringUpdate(ctx context.Context, key string, obj, existing runtime.Object) bool

ShouldDeleteDuringUpdate is the default function for checking if an object should be deleted during an update. It checks if the new object has no finalizers, the existing object's deletionTimestamp is set, and the existing object's deletionGracePeriodSeconds is 0 or nil

func StorageWithCacher 

func StorageWithCacher(capacity int) generic.StorageDecorator

Creates a cacher based given storageConfig.

func TrackStorageCleanup 

func TrackStorageCleanup()

Types

type DryRunnableStorage 

type DryRunnableStorage struct {
	Storage storage.Interface
	Codec   runtime.Codec
}

func (*DryRunnableStorage) Count 

func (s *DryRunnableStorage) Count(key string) (int64, error)

func (*DryRunnableStorage) Create 

func (s *DryRunnableStorage) Create(ctx context.Context, key string, obj, out runtime.Object, ttl uint64, dryRun bool) error

func (*DryRunnableStorage) Delete 

func (s *DryRunnableStorage) Delete(ctx context.Context, key string, out runtime.Object, preconditions *storage.Preconditions, deleteValidation storage.ValidateObjectFunc, dryRun bool) error

func (*DryRunnableStorage) Get 

func (s *DryRunnableStorage) Get(ctx context.Context, key string, resourceVersion string, objPtr runtime.Object, ignoreNotFound bool) error

func (*DryRunnableStorage) GetToList 

func (s *DryRunnableStorage) GetToList(ctx context.Context, key string, resourceVersion string, p storage.SelectionPredicate, listObj runtime.Object) error

func (*DryRunnableStorage) GuaranteedUpdate 

func (s *DryRunnableStorage) GuaranteedUpdate(
	ctx context.Context, key string, ptrToType runtime.Object, ignoreNotFound bool,
	preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, dryRun bool, suggestion ...runtime.Object) error

func (*DryRunnableStorage) List 

func (s *DryRunnableStorage) List(ctx context.Context, key string, resourceVersion string, p storage.SelectionPredicate, listObj runtime.Object) error

func (*DryRunnableStorage) Versioner 

func (s *DryRunnableStorage) Versioner() storage.Versioner

func (*DryRunnableStorage) Watch 

func (s *DryRunnableStorage) Watch(ctx context.Context, key string, resourceVersion string, p storage.SelectionPredicate) (watch.Interface, error)

func (*DryRunnableStorage) WatchList 

func (s *DryRunnableStorage) WatchList(ctx context.Context, key string, resourceVersion string, p storage.SelectionPredicate) (watch.Interface, error)

type GenericStore 

type GenericStore interface {
	GetCreateStrategy() rest.RESTCreateStrategy
	GetUpdateStrategy() rest.RESTUpdateStrategy
	GetDeleteStrategy() rest.RESTDeleteStrategy
	GetExportStrategy() rest.RESTExportStrategy
}

GenericStore interface can be used for type assertions when we need to access the underlying strategies.

type ObjectFunc 

type ObjectFunc func(obj runtime.Object) error

ObjectFunc is a function to act on a given object. An error may be returned if the hook cannot be completed. An ObjectFunc may transform the provided object.

type Store 

type Store struct {
	// NewFunc returns a new instance of the type this registry returns for a
	// GET of a single object, e.g.:
	//
	// curl GET /apis/group/version/namespaces/my-ns/myresource/name-of-object
	NewFunc func() runtime.Object

	// NewListFunc returns a new list of the type this registry; it is the
	// type returned when the resource is listed, e.g.:
	//
	// curl GET /apis/group/version/namespaces/my-ns/myresource
	NewListFunc func() runtime.Object

	// DefaultQualifiedResource is the pluralized name of the resource.
	// This field is used if there is no request info present in the context.
	// See qualifiedResourceFromContext for details.
	DefaultQualifiedResource schema.GroupResource

	// KeyRootFunc returns the root etcd key for this resource; should not
	// include trailing "/".  This is used for operations that work on the
	// entire collection (listing and watching).
	//
	// KeyRootFunc and KeyFunc must be supplied together or not at all.
	KeyRootFunc func(ctx context.Context) string

	// KeyFunc returns the key for a specific object in the collection.
	// KeyFunc is called for Create/Update/Get/Delete. Note that 'namespace'
	// can be gotten from ctx.
	//
	// KeyFunc and KeyRootFunc must be supplied together or not at all.
	KeyFunc func(ctx context.Context, name string) (string, error)

	// ObjectNameFunc returns the name of an object or an error.
	ObjectNameFunc func(obj runtime.Object) (string, error)

	// TTLFunc returns the TTL (time to live) that objects should be persisted
	// with. The existing parameter is the current TTL or the default for this
	// operation. The update parameter indicates whether this is an operation
	// against an existing object.
	//
	// Objects that are persisted with a TTL are evicted once the TTL expires.
	TTLFunc func(obj runtime.Object, existing uint64, update bool) (uint64, error)

	// PredicateFunc returns a matcher corresponding to the provided labels
	// and fields. The SelectionPredicate returned should return true if the
	// object matches the given field and label selectors.
	PredicateFunc func(label labels.Selector, field fields.Selector) storage.SelectionPredicate

	// EnableGarbageCollection affects the handling of Update and Delete
	// requests. Enabling garbage collection allows finalizers to do work to
	// finalize this object before the store deletes it.
	//
	// If any store has garbage collection enabled, it must also be enabled in
	// the kube-controller-manager.
	EnableGarbageCollection bool

	// DeleteCollectionWorkers is the maximum number of workers in a single
	// DeleteCollection call. Delete requests for the items in a collection
	// are issued in parallel.
	DeleteCollectionWorkers int

	// Decorator is an optional exit hook on an object returned from the
	// underlying storage. The returned object could be an individual object
	// (e.g. Pod) or a list type (e.g. PodList). Decorator is intended for
	// integrations that are above storage and should only be used for
	// specific cases where storage of the value is not appropriate, since
	// they cannot be watched.
	Decorator ObjectFunc
	// CreateStrategy implements resource-specific behavior during creation.
	CreateStrategy rest.RESTCreateStrategy
	// AfterCreate implements a further operation to run after a resource is
	// created and before it is decorated, optional.
	AfterCreate ObjectFunc

	// UpdateStrategy implements resource-specific behavior during updates.
	UpdateStrategy rest.RESTUpdateStrategy
	// AfterUpdate implements a further operation to run after a resource is
	// updated and before it is decorated, optional.
	AfterUpdate ObjectFunc

	// DeleteStrategy implements resource-specific behavior during deletion.
	DeleteStrategy rest.RESTDeleteStrategy
	// AfterDelete implements a further operation to run after a resource is
	// deleted and before it is decorated, optional.
	AfterDelete ObjectFunc
	// ReturnDeletedObject determines whether the Store returns the object
	// that was deleted. Otherwise, return a generic success status response.
	ReturnDeletedObject bool
	// ShouldDeleteDuringUpdate is an optional function to determine whether
	// an update from existing to obj should result in a delete.
	// If specified, this is checked in addition to standard finalizer,
	// deletionTimestamp, and deletionGracePeriodSeconds checks.
	ShouldDeleteDuringUpdate func(ctx context.Context, key string, obj, existing runtime.Object) bool
	// ExportStrategy implements resource-specific behavior during export,
	// optional. Exported objects are not decorated.
	ExportStrategy rest.RESTExportStrategy
	// TableConvertor is an optional interface for transforming items or lists
	// of items into tabular output. If unset, the default will be used.
	TableConvertor rest.TableConvertor

	// Storage is the interface for the underlying storage for the
	// resource. It is wrapped into a "DryRunnableStorage" that will
	// either pass-through or simply dry-run.
	Storage DryRunnableStorage
	// StorageVersioner outputs the <group/version/kind> an object will be
	// converted to before persisted in etcd, given a list of possible
	// kinds of the object.
	// If the StorageVersioner is nil, apiserver will leave the
	// storageVersionHash as empty in the discovery document.
	StorageVersioner runtime.GroupVersioner
	// Called to cleanup clients used by the underlying Storage; optional.
	DestroyFunc func()
}

Store implements pkg/api/rest.StandardStorage. It's intended to be embeddable and allows the consumer to implement any non-generic functions that are required. This object is intended to be copyable so that it can be used in different ways but share the same underlying behavior.

All fields are required unless specified.

The intended use of this type is embedding within a Kind specific RESTStorage implementation. This type provides CRUD semantics on a Kubelike resource, handling details like conflict detection with ResourceVersion and semantics. The RESTCreateStrategy, RESTUpdateStrategy, and RESTDeleteStrategy are generic across all backends, and encapsulate logic specific to the API.

TODO: make the default exposed methods exactly match a generic RESTStorage

func (*Store) CompleteWithOptions 

func (e *Store) CompleteWithOptions(options *generic.StoreOptions) error

CompleteWithOptions updates the store with the provided options and defaults common fields.

func (*Store) ConvertToTable 

func (e *Store) ConvertToTable(ctx context.Context, object runtime.Object, tableOptions runtime.Object) (*metav1.Table, error)

func (*Store) Create 

func (e *Store) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error)

Create inserts a new item according to the unique key from the object.

func (*Store) Delete 

func (e *Store) Delete(ctx context.Context, name string, deleteValidation rest.ValidateObjectFunc, options *metav1.DeleteOptions) (runtime.Object, bool, error)

Delete removes the item from storage.

func (*Store) DeleteCollection 

func (e *Store) DeleteCollection(ctx context.Context, deleteValidation rest.ValidateObjectFunc, options *metav1.DeleteOptions, listOptions *metainternalversion.ListOptions) (runtime.Object, error)

DeleteCollection removes all items returned by List with a given ListOptions from storage.

DeleteCollection is currently NOT atomic. It can happen that only subset of objects will be deleted from storage, and then an error will be returned. In case of success, the list of deleted objects will be returned.

TODO: Currently, there is no easy way to remove 'directory' entry from storage (if we are removing all objects of a given type) with the current API (it's technically possibly with storage API, but watch is not delivered correctly then). It will be possible to fix it with v3 etcd API.

func (*Store) DeleteReturnsDeletedObject added in v0.18.0 

func (e *Store) DeleteReturnsDeletedObject() bool

DeleteReturnsDeletedObject implements the rest.MayReturnFullObjectDeleter interface

func (*Store) Export 

func (e *Store) Export(ctx context.Context, name string, opts metav1.ExportOptions) (runtime.Object, error)

Export implements the rest.Exporter interface

func (*Store) Get 

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

Get retrieves the item from storage.

func (*Store) GetCreateStrategy 

func (e *Store) GetCreateStrategy() rest.RESTCreateStrategy

GetCreateStrategy implements GenericStore.

func (*Store) GetDeleteStrategy 

func (e *Store) GetDeleteStrategy() rest.RESTDeleteStrategy

GetDeleteStrategy implements GenericStore.

func (*Store) GetExportStrategy 

func (e *Store) GetExportStrategy() rest.RESTExportStrategy

GetExportStrategy implements GenericStore.

func (*Store) GetUpdateStrategy 

func (e *Store) GetUpdateStrategy() rest.RESTUpdateStrategy

GetUpdateStrategy implements GenericStore.

func (*Store) List 

func (e *Store) List(ctx context.Context, options *metainternalversion.ListOptions) (runtime.Object, error)

List returns a list of items matching labels and field according to the store's PredicateFunc.

func (*Store) ListPredicate 

func (e *Store) ListPredicate(ctx context.Context, p storage.SelectionPredicate, options *metainternalversion.ListOptions) (runtime.Object, error)

ListPredicate returns a list of all the items matching the given SelectionPredicate.

func (*Store) NamespaceScoped 

func (e *Store) NamespaceScoped() bool

NamespaceScoped indicates whether the resource is namespaced

func (*Store) New 

func (e *Store) New() runtime.Object

New implements RESTStorage.New.

func (*Store) NewList 

func (e *Store) NewList() runtime.Object

NewList implements rest.Lister.

func (*Store) StorageVersion 

func (e *Store) StorageVersion() runtime.GroupVersioner

func (*Store) Update 

func (e *Store) 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 performs an atomic update and set of the object. Returns the result of the update or an error. If the registry allows create-on-update, the create flow will be executed. A bool is returned along with the object and any errors, to indicate object creation.

func (*Store) Watch 

func (e *Store) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error)

Watch makes a matcher for the given label and field, and calls WatchPredicate. If possible, you should customize PredicateFunc to produce a matcher that matches by key. SelectionPredicate does this for you automatically.

func (*Store) WatchPredicate 

func (e *Store) WatchPredicate(ctx context.Context, p storage.SelectionPredicate, resourceVersion string) (watch.Interface, error)

WatchPredicate starts a watch for the items that matches.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.