datapackaging

package
v0.28.0 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PackageCRDREST 

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

PackageCRDREST is a rest implementation that proxies the rest endpoints provided by CRDs. This will allow us to introduce the api server without the complexities associated with custom storage options for now.

func NewPackageCRDREST 

func NewPackageCRDREST(crdClient installclient.Interface, nsClient kubernetes.Interface, globalNS string) *PackageCRDREST

func (*PackageCRDREST) ConvertToTable 

func (r *PackageCRDREST) ConvertToTable(ctx context.Context, obj runtime.Object, tableOptions runtime.Object) (*metav1.Table, error)

func (*PackageCRDREST) Create 

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

func (*PackageCRDREST) Delete 

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

func (*PackageCRDREST) DeleteCollection 

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

func (*PackageCRDREST) Get 

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

func (*PackageCRDREST) List 

func (r *PackageCRDREST) List(ctx context.Context, options *internalversion.ListOptions) (runtime.Object, error)

func (*PackageCRDREST) NamespaceScoped 

func (r *PackageCRDREST) NamespaceScoped() bool

func (*PackageCRDREST) New 

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

func (*PackageCRDREST) NewList 

func (r *PackageCRDREST) NewList() runtime.Object

func (*PackageCRDREST) ShortNames 

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

func (*PackageCRDREST) Update 

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

func (*PackageCRDREST) Watch 

func (r *PackageCRDREST) Watch(ctx context.Context, options *internalversion.ListOptions) (watch.Interface, error)

type PackageMetadataCRDREST 

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

PackageMetadataCRDREST is a rest implementation that proxies the rest endpoints provided by CRDs. This will allow us to introduce the api server without the complexities associated with custom storage options for now.

func NewPackageMetadataCRDREST 

func NewPackageMetadataCRDREST(crdClient installclient.Interface, nsClient kubernetes.Interface, globalNS string) *PackageMetadataCRDREST

func (*PackageMetadataCRDREST) ConvertToTable 

func (r *PackageMetadataCRDREST) ConvertToTable(ctx context.Context, obj runtime.Object, tableOptions runtime.Object) (*metav1.Table, error)

func (*PackageMetadataCRDREST) Create 

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

func (*PackageMetadataCRDREST) Delete 

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

func (*PackageMetadataCRDREST) DeleteCollection 

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

func (*PackageMetadataCRDREST) Get 

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

func (*PackageMetadataCRDREST) List 

func (r *PackageMetadataCRDREST) List(ctx context.Context, options *internalversion.ListOptions) (runtime.Object, error)

func (*PackageMetadataCRDREST) NamespaceScoped 

func (r *PackageMetadataCRDREST) NamespaceScoped() bool

func (*PackageMetadataCRDREST) New 

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

func (*PackageMetadataCRDREST) NewList 

func (r *PackageMetadataCRDREST) NewList() runtime.Object

func (*PackageMetadataCRDREST) ShortNames 

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

func (*PackageMetadataCRDREST) Update 

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

func (*PackageMetadataCRDREST) Watch 

func (r *PackageMetadataCRDREST) Watch(ctx context.Context, options *internalversion.ListOptions) (watch.Interface, error)

type PackageMetadataStorageClient 

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

func NewPackageMetadataStorageClient 

func NewPackageMetadataStorageClient(crdClient internalclient.Interface, translator PackageMetadataTranslator) *PackageMetadataStorageClient

func (PackageMetadataStorageClient) Create 

func (psc PackageMetadataStorageClient) Create(ctx context.Context, namespace string, obj *datapackaging.PackageMetadata, opts metav1.CreateOptions) (*datapackaging.PackageMetadata, error)

func (PackageMetadataStorageClient) Delete 

func (psc PackageMetadataStorageClient) Delete(ctx context.Context, namespace, name string, opts metav1.DeleteOptions) error

func (PackageMetadataStorageClient) Get 

func (psc PackageMetadataStorageClient) Get(ctx context.Context, namespace, name string, opts metav1.GetOptions) (*datapackaging.PackageMetadata, error)

func (PackageMetadataStorageClient) List 

func (psc PackageMetadataStorageClient) List(ctx context.Context, namespace string, opts metav1.ListOptions) (*datapackaging.PackageMetadataList, error)

func (PackageMetadataStorageClient) Update 

func (psc PackageMetadataStorageClient) Update(ctx context.Context, namespace string, updatedObj *datapackaging.PackageMetadata, opts metav1.UpdateOptions) (*datapackaging.PackageMetadata, error)

func (PackageMetadataStorageClient) Watch 

func (psc PackageMetadataStorageClient) Watch(ctx context.Context, namespace string, opts metav1.ListOptions) (watch.Interface, error)

type PackageMetadataTranslator 

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

func NewPackageMetadataTranslator 

func NewPackageMetadataTranslator(namespace string) PackageMetadataTranslator

func (PackageMetadataTranslator) ToExternalError 

func (t PackageMetadataTranslator) ToExternalError(err error) error

func (PackageMetadataTranslator) ToExternalList 

func (t PackageMetadataTranslator) ToExternalList(intObjList *internalpkgingv1alpha1.InternalPackageMetadataList) *datapackaging.PackageMetadataList

func (PackageMetadataTranslator) ToExternalObj 

func (t PackageMetadataTranslator) ToExternalObj(intObj *internalpkgingv1alpha1.InternalPackageMetadata) *datapackaging.PackageMetadata

func (PackageMetadataTranslator) ToExternalWatcher 

func (t PackageMetadataTranslator) ToExternalWatcher(intObjWatcher watch.Interface) watch.Interface

func (PackageMetadataTranslator) ToInternalObj 

func (t PackageMetadataTranslator) ToInternalObj(extObj *datapackaging.PackageMetadata) *internalpkgingv1alpha1.InternalPackageMetadata

type PackageStorageClient 

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

func NewPackageStorageClient 

func NewPackageStorageClient(crdClient internalclient.Interface, translator PackageTranslator) *PackageStorageClient

func (PackageStorageClient) Create 

func (psc PackageStorageClient) Create(ctx context.Context, namespace string, obj *datapackaging.Package, opts metav1.CreateOptions) (*datapackaging.Package, error)

func (PackageStorageClient) Delete 

func (psc PackageStorageClient) Delete(ctx context.Context, namespace, name string, opts metav1.DeleteOptions) error

func (PackageStorageClient) Get 

func (psc PackageStorageClient) Get(ctx context.Context, namespace, name string, opts metav1.GetOptions) (*datapackaging.Package, error)

func (PackageStorageClient) List 

func (psc PackageStorageClient) List(ctx context.Context, namespace string, opts metav1.ListOptions) (*datapackaging.PackageList, error)

func (PackageStorageClient) Update 

func (psc PackageStorageClient) Update(ctx context.Context, namespace string, updatedObj *datapackaging.Package, opts metav1.UpdateOptions) (*datapackaging.Package, error)

func (PackageStorageClient) Watch 

func (psc PackageStorageClient) Watch(ctx context.Context, namespace string, opts metav1.ListOptions) (watch.Interface, error)

type PackageTranslator 

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

func NewPackageTranslator 

func NewPackageTranslator(namespace string) PackageTranslator

func (PackageTranslator) ToExternalError 

func (t PackageTranslator) ToExternalError(err error) error

func (PackageTranslator) ToExternalList 

func (t PackageTranslator) ToExternalList(intObjList *internalpkgingv1alpha1.InternalPackageList) (*datapackaging.PackageList, error)

func (PackageTranslator) ToExternalName 

func (t PackageTranslator) ToExternalName(name string) (string, error)

func (PackageTranslator) ToExternalObj 

func (t PackageTranslator) ToExternalObj(intObj *internalpkgingv1alpha1.InternalPackage) (*datapackaging.Package, error)

func (PackageTranslator) ToExternalWatcher 

func (t PackageTranslator) ToExternalWatcher(intObjWatcher watch.Interface, fieldSelector fields.Selector) watch.Interface

func (PackageTranslator) ToInternalName 

func (t PackageTranslator) ToInternalName(name string) string

func (PackageTranslator) ToInternalObj 

func (t PackageTranslator) ToInternalObj(extObj *datapackaging.Package) *internalpkgingv1alpha1.InternalPackage

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.