tekton

Documentation

Index

• Constants
• Variables
• func NewTektonClientAndResolvedNamespace(defaultNamespace string) (*v1beta1.TektonV1beta1Client, string, error)
• func NewTektonClientset() (versioned.Interface, error)
• type ErrRuntimeNotSupported
  • func (e ErrRuntimeNotSupported) Error() string
• type Opt
  • func WithCredentialsProvider(credentialsProvider docker.CredentialsProvider) Opt
  • func WithNamespace(namespace string) Opt
  • func WithPipelineDecorator(decorator PipelineDecorator) Opt
  • func WithProgressListener(pl fn.ProgressListener) Opt
  • func WithVerbose(verbose bool) Opt
• type PipelineDecorator
• type PipelinesProvider
  • func NewPipelinesProvider(opts ...Opt) *PipelinesProvider
  • func (pp *PipelinesProvider) Remove(ctx context.Context, f fn.Function) error
  • func (pp *PipelinesProvider) Run(ctx context.Context, f fn.Function) error

Constants

const (
	// DefaultPersistentVolumeClaimSize represents default size of PVC created for a Pipeline,
	// specified in bytes (eg. 5Mi = 5MiB = 5 * 1024 * 1024)
	DefaultPersistentVolumeClaimSize int64 = 5 * 1024 * 1024
)

const (
	DefaultWaitingTimeout = 120 * time.Second
)

Variables

var (
	// ErrRuntimeRequired indicates the required value of Function Runtime was not provided
	ErrRuntimeRequired = errors.New("runtime is required to build")

	ErrBuilpacksNotSupported = errors.New("additional Buildpacks are not supported for on cluster build")
)

Functions

func NewTektonClientAndResolvedNamespace

func NewTektonClientAndResolvedNamespace(defaultNamespace string) (*v1beta1.TektonV1beta1Client, string, error)

func NewTektonClientset

func NewTektonClientset() (versioned.Interface, error)

Types

type ErrRuntimeNotSupported

type ErrRuntimeNotSupported struct {
	Runtime string
}

func (ErrRuntimeNotSupported) Error

func (e ErrRuntimeNotSupported) Error() string

type Opt

type Opt func(*PipelinesProvider)

func WithCredentialsProvider

func WithCredentialsProvider(credentialsProvider docker.CredentialsProvider) Opt

func WithNamespace

func WithNamespace(namespace string) Opt

func WithPipelineDecorator

func WithPipelineDecorator(decorator PipelineDecorator) Opt

func WithProgressListener

func WithProgressListener(pl fn.ProgressListener) Opt

func WithVerbose

func WithVerbose(verbose bool) Opt

type PipelineDecorator

type PipelineDecorator interface {
	UpdateLabels(fn.Function, map[string]string) map[string]string
}

type PipelinesProvider

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

func NewPipelinesProvider

func NewPipelinesProvider(opts ...Opt) *PipelinesProvider

func (*PipelinesProvider) Remove

func (pp *PipelinesProvider) Remove(ctx context.Context, f fn.Function) error

func (*PipelinesProvider) Run

func (pp *PipelinesProvider) Run(ctx context.Context, f fn.Function) error

Run creates a Tekton Pipeline and all necessary resources (PVCs, Secrets, SAs,...) for the input Function. It ensures that all needed resources are present on the cluster so the PipelineRun can be initialized. After the PipelineRun is being intitialized, the progress of the PipelineRun is being watched and printed to the output.