pipeline

package

v0.2.1 Latest Latest Go to latest Published: Nov 17, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func Run(ctx context.Context, name string, opts ...Option) error

Run a processor.

type ChainProcessorFunc func(Context, *bundlev1.SecretChain) error

ChainProcessorFunc describes a secret chain object processor contract.

type Context interface {
	GetFile() *bundlev1.Bundle
	GetPackage() *bundlev1.Package
	GetSecret() *bundlev1.SecretChain
	GetKeyValue() *bundlev1.KV
}

Context defines tree processing context.

type FileProcessorFunc func(Context, *bundlev1.Bundle) error

FileProcessorFunc describes a file object processor contract.

type KVProcessorFunc func(Context, *bundlev1.KV) error

KVProcessorFunc describes a kv object processor contract.

type Option func(*Options)

Option represents option function

func ChainProcessor(f ChainProcessorFunc) Option

ChainProcessor assign the chain object processor.

func FileProcessor(f FileProcessorFunc) Option

FileProcessor assign the file object processor.

func KVProcessor(f KVProcessorFunc) Option

KVProcessor assign the KV object processor.

func OutputDisabled() Option

OutputDisabled assign the value to disableOutput option.

func PackageProcessor(f PackageProcessorFunc) Option

PackageProcessor assign the package object processor.

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

Options defines default options.

type PackageProcessorFunc func(Context, *bundlev1.Package) error

PackageProcessorFunc describes a package object processor contract.

type Processor func(context.Context, *bundlev1.Bundle) error

Processor declares a bundle processor contract