revision

package
v0.2.23 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2022 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PackageRevision 

func PackageRevision(pr v1.PackageRevision) parser.BackendOption

PackageRevision sets the package revision for ImageBackend.

func SetupProviderRevision 

func SetupProviderRevision(mgr ctrl.Manager, l logging.Logger, cache nddpkg.Cache, namespace string) error

SetupProviderRevision adds a controller that reconciles ProviderRevisions.

Types

type APIEstablisher 

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

APIEstablisher establishes control or ownership of resources in the API server for a parent.

func NewAPIEstablisher 

func NewAPIEstablisher(client client.Client) *APIEstablisher

NewAPIEstablisher creates a new APIEstablisher.

func (*APIEstablisher) Establish 

func (e *APIEstablisher) Establish(ctx context.Context, objs []runtime.Object, parent resource.Object, control bool) ([]nddv1.TypedReference, error)

Establish checks that control or ownership of resources can be established by parent, then establishes it.

type DependencyManager 

type DependencyManager interface {
	Resolve(ctx context.Context, pkg runtime.Object, pr v1.PackageRevision) (found, installed, invalid int, err error)
	RemoveSelf(ctx context.Context, pr v1.PackageRevision) error
}

DependencyManager is a lock on packages.

type Establisher 

type Establisher interface {
	Establish(ctx context.Context, objects []runtime.Object, parent resource.Object, control bool) ([]nddv1.TypedReference, error)
}

An Establisher establishes control or ownership of a set of resources in the API server by checking that control or ownership can be established for all resources and then establishing it.

type Hooks 

type Hooks interface {
	// Pre performs operations meant to happen before establishing objects.
	Pre(context.Context, runtime.Object, pkgv1.PackageRevision, []string) error

	// Post performs operations meant to happen after establishing objects.
	Post(context.Context, runtime.Object, pkgv1.PackageRevision, []string) error
}

A Hooks performs operations before and after a revision establishes objects.

type ImageBackend 

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

ImageBackend is a backend for parser.

func NewImageBackend 

func NewImageBackend(cache nddpkg.Cache, fetcher nddpkg.Fetcher) *ImageBackend

NewImageBackend creates a new image backend.

func (*ImageBackend) Init 

func (i *ImageBackend) Init(ctx context.Context, bo ...parser.BackendOption) (io.ReadCloser, error)

Init initializes an ImageBackend.

type NopHooks 

type NopHooks struct{}

NopHooks performs no operations.

func NewNopHooks 

func NewNopHooks() *NopHooks

NewNopHooks creates a hook that does nothing.

func (*NopHooks) Post 

func (h *NopHooks) Post(context.Context, runtime.Object, pkgv1.PackageRevision, []string) error

Post does nothing and returns nil.

func (*NopHooks) Pre 

func (h *NopHooks) Pre(context.Context, runtime.Object, pkgv1.PackageRevision, []string) error

Pre does nothing and returns nil.

type Options added in v0.2.21 

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

type PackageDependencyManager 

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

PackageDependencyManager is a resolver for packages.

func NewPackageDependencyManager 

func NewPackageDependencyManager(c client.Client, nd dag.NewDAGFn, t pkgmetav1.PackageType) *PackageDependencyManager

NewPackageDependencyManager creates a new PackageDependencyManager.

func (*PackageDependencyManager) RemoveSelf 

func (m *PackageDependencyManager) RemoveSelf(ctx context.Context, pr v1.PackageRevision) error

RemoveSelf removes a package from the lock.

func (*PackageDependencyManager) Resolve 

func (m *PackageDependencyManager) Resolve(ctx context.Context, pkg runtime.Object, pr v1.PackageRevision) (found, installed, invalid int, err error)

Resolve resolves package dependencies.

type ProviderHooks 

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

ProviderHooks performs operations for a Provider package that requires a controller before and after the revision establishes objects.

func NewProviderHooks 

func NewProviderHooks(client resource.ClientApplicator, namespace string, l logging.Logger) *ProviderHooks

NewProviderHooks creates a new ProviderHooks.

func (*ProviderHooks) Post 

func (h *ProviderHooks) Post(ctx context.Context, pkg runtime.Object, pr pkgv1.PackageRevision, crdNames []string) error

Post creates a packaged provider controller and service account if the revision is active.

func (*ProviderHooks) Pre 

func (h *ProviderHooks) Pre(ctx context.Context, pkg runtime.Object, pr pkgv1.PackageRevision, crdNames []string) error

Pre cleans up a packaged controller and service account if the revision is inactive.

type Reconciler 

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

Reconciler reconciles packages.

func NewReconciler 

func NewReconciler(mgr manager.Manager, opts ...ReconcilerOption) *Reconciler

NewReconciler creates a new package revision reconciler.

func (*Reconciler) Reconcile 

func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

Reconcile package revision.

type ReconcilerOption 

type ReconcilerOption func(*Reconciler)

ReconcilerOption is used to configure the Reconciler.

func WithCache 

func WithCache(c nddpkg.Cache) ReconcilerOption

WithCache specifies how the Reconcile should cache package contents.

func WithClientApplicator 

func WithClientApplicator(ca resource.ClientApplicator) ReconcilerOption

WithClientApplicator specifies how the Reconciler should interact with the Kubernetes API.

func WithDependencyManager 

func WithDependencyManager(m DependencyManager) ReconcilerOption

WithDependencyManager specifies how the Reconciler should manage dependencies.

func WithEstablisher 

func WithEstablisher(e Establisher) ReconcilerOption

WithEstablisher specifies how the Reconciler should establish package resources.

func WithFinalizer 

func WithFinalizer(f resource.Finalizer) ReconcilerOption

WithFinalizer specifies how the Reconciler should finalize package revisions.

func WithHooks 

func WithHooks(h Hooks) ReconcilerOption

WithHooks specifies how the Reconciler should perform pre and post object establishment operations.

func WithLinter 

func WithLinter(l parser.Linter) ReconcilerOption

WithLinter specifies how the Reconciler should lint a package.

func WithLogger 

func WithLogger(log logging.Logger) ReconcilerOption

WithLogger specifies how the Reconciler should log messages.

func WithNewPackageRevisionFn 

func WithNewPackageRevisionFn(f func() pkgv1.PackageRevision) ReconcilerOption

WithNewPackageRevisionFn determines the type of package being reconciled.

func WithParser 

func WithParser(p parser.Parser) ReconcilerOption

WithParser specifies how the Reconciler should parse a package.

func WithParserBackend 

func WithParserBackend(p parser.Backend) ReconcilerOption

WithParserBackend specifies how the Reconciler should parse a package.

func WithRecorder 

func WithRecorder(er event.Recorder) ReconcilerOption

WithRecorder specifies how the Reconciler should record Kubernetes events.

func WithVersioner 

func WithVersioner(v version.Operations) ReconcilerOption

WithVersioner specifies how the Reconciler should fetch the current Ndd version.

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.