revision

Documentation

Index

• func PackageRevision(pr v1.PackageRevision) parser.BackendOption
• func SetupProviderRevision(mgr ctrl.Manager, l logging.Logger, cache nddpkg.Cache, namespace string) error
• type APIEstablisher
  • func NewAPIEstablisher(client client.Client) *APIEstablisher
  • func (e *APIEstablisher) Establish(ctx context.Context, objs []runtime.Object, parent resource.Object, ...) ([]nddv1.TypedReference, error)
• type DependencyManager
• type Establisher
• type Hooks
• type ImageBackend
  • func NewImageBackend(cache nddpkg.Cache, fetcher nddpkg.Fetcher) *ImageBackend
  • func (i *ImageBackend) Init(ctx context.Context, bo ...parser.BackendOption) (io.ReadCloser, error)
• type NopHooks
  • func NewNopHooks() *NopHooks
  • func (h *NopHooks) Post(context.Context, runtime.Object, pkgv1.PackageRevision, []string) error
  • func (h *NopHooks) Pre(context.Context, runtime.Object, pkgv1.PackageRevision, []string) error
• type Options
• type PackageDependencyManager
  • func NewPackageDependencyManager(c client.Client, nd dag.NewDAGFn, t pkgmetav1.PackageType) *PackageDependencyManager
  • func (m *PackageDependencyManager) RemoveSelf(ctx context.Context, pr v1.PackageRevision) error
  • func (m *PackageDependencyManager) Resolve(ctx context.Context, pkg runtime.Object, pr v1.PackageRevision) (found, installed, invalid int, err error)
• type ProviderHooks
  • func NewProviderHooks(client resource.ClientApplicator, namespace string, l logging.Logger) *ProviderHooks
  • func (h *ProviderHooks) Post(ctx context.Context, pkg runtime.Object, pr pkgv1.PackageRevision, ...) error
  • func (h *ProviderHooks) Pre(ctx context.Context, pkg runtime.Object, pr pkgv1.PackageRevision, ...) error
• type Reconciler
  • func NewReconciler(mgr manager.Manager, opts ...ReconcilerOption) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type ReconcilerOption
  • func WithCache(c nddpkg.Cache) ReconcilerOption
  • func WithClientApplicator(ca resource.ClientApplicator) ReconcilerOption
  • func WithDependencyManager(m DependencyManager) ReconcilerOption
  • func WithEstablisher(e Establisher) ReconcilerOption
  • func WithFinalizer(f resource.Finalizer) ReconcilerOption
  • func WithHooks(h Hooks) ReconcilerOption
  • func WithLinter(l parser.Linter) ReconcilerOption
  • func WithLogger(log logging.Logger) ReconcilerOption
  • func WithNewPackageRevisionFn(f func() pkgv1.PackageRevision) ReconcilerOption
  • func WithParser(p parser.Parser) ReconcilerOption
  • func WithParserBackend(p parser.Backend) ReconcilerOption
  • func WithRecorder(er event.Recorder) ReconcilerOption
  • func WithVersioner(v version.Operations) ReconcilerOption

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

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.