keptntask

Documentation

Index

• Constants
• type BuilderOptions
• type ContainerBuilder
  • func NewContainerBuilder(options BuilderOptions) *ContainerBuilder
  • func (c *ContainerBuilder) CreateContainer(ctx context.Context) (*corev1.Container, error)
  • func (c *ContainerBuilder) CreateVolume(ctx context.Context) (*corev1.Volume, error)
• type JobRunnerBuilder
  • func NewJobRunnerBuilder(options BuilderOptions) JobRunnerBuilder
• type KeptnTaskReconciler
  • func (r *KeptnTaskReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KeptnTaskReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RuntimeBuilder
  • func NewRuntimeBuilder(options BuilderOptions) *RuntimeBuilder
  • func (fb *RuntimeBuilder) CreateContainer(ctx context.Context) (*corev1.Container, error)
  • func (fb *RuntimeBuilder) CreateVolume(ctx context.Context) (*corev1.Volume, error)
• type RuntimeExecutionParams

Constants

const (
	Context           = "CONTEXT"
	SecureData        = "SECURE_DATA"
	Data              = "DATA"
	CmdArgs           = "CMD_ARGS"
	Script            = "SCRIPT"
	FunctionMountName = "function-mount"
)

Types

type BuilderOptions

type BuilderOptions struct {
	client.Client

	Log logr.Logger

	Image     string
	MountPath string
	ConfigMap string
	// contains filtered or unexported fields
}

BuilderOptions contains everything needed to build the current job

type ContainerBuilder

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

ContainerBuilder implements container builder interface for python

func NewContainerBuilder

func NewContainerBuilder(options BuilderOptions) *ContainerBuilder

func (*ContainerBuilder) CreateContainer

func (c *ContainerBuilder) CreateContainer(ctx context.Context) (*corev1.Container, error)

func (*ContainerBuilder) CreateVolume

func (c *ContainerBuilder) CreateVolume(ctx context.Context) (*corev1.Volume, error)

type JobRunnerBuilder

type JobRunnerBuilder interface {
	// CreateContainerWithVolumes returns a job container and volumes based on the task definition spec
	CreateContainer(ctx context.Context) (*corev1.Container, error)
	CreateVolume(ctx context.Context) (*corev1.Volume, error)
}

JobRunnerBuilder is the interface that describes the operations needed to help build job specs of a task

func NewJobRunnerBuilder

func NewJobRunnerBuilder(options BuilderOptions) JobRunnerBuilder

type KeptnTaskReconciler

type KeptnTaskReconciler struct {
	client.Client
	Scheme        *runtime.Scheme
	EventSender   controllercommon.EventSender
	Log           logr.Logger
	Meters        apicommon.KeptnMeters
	TracerFactory controllercommon.TracerFactory
}

KeptnTaskReconciler reconciles a KeptnTask object

func (*KeptnTaskReconciler) Reconcile

func (r *KeptnTaskReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KeptnTaskReconciler) SetupWithManager

func (r *KeptnTaskReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RuntimeBuilder

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

RuntimeBuilder implements container builder interface for Deno/Python

func NewRuntimeBuilder

func NewRuntimeBuilder(options BuilderOptions) *RuntimeBuilder

func (*RuntimeBuilder) CreateContainer

func (fb *RuntimeBuilder) CreateContainer(ctx context.Context) (*corev1.Container, error)

func (*RuntimeBuilder) CreateVolume

func (fb *RuntimeBuilder) CreateVolume(ctx context.Context) (*corev1.Volume, error)

type RuntimeExecutionParams

type RuntimeExecutionParams struct {
	ConfigMap        string
	Parameters       map[string]string
	SecureParameters string
	CmdParameters    string
	URL              string
	Context          klcv1alpha3.TaskContext
	Image            string
	MountPath        string
}

RuntimeExecutionParams stores parameters related to Deno/Python container creation