Documentation
¶
Index ¶
- func NewContainerRunner(ctx context.Context, f *kptfilev1alpha2.Function, pkgPath types.UniquePath) (kio.Filter, error)
- func NewFunctionRunner(ctx context.Context, fltr *runtimeutil.FunctionFilter, name string, ...) (kio.Filter, error)
- type ContainerFn
- type ContainerFnPermission
- type ExecFn
- type FunctionRunner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContainerRunner ¶
func NewContainerRunner(ctx context.Context, f *kptfilev1alpha2.Function, pkgPath types.UniquePath) (kio.Filter, error)
NewContainerRunner returns a kio.Filter given a specification of a container function and it's config.
func NewFunctionRunner ¶
func NewFunctionRunner(ctx context.Context, fltr *runtimeutil.FunctionFilter, name string, disableOutput bool) (kio.Filter, error)
NewFunctionRunner returns a kio.Filter given a specification of a function and it's config.
Types ¶
type ContainerFn ¶
type ContainerFn struct {
Ctx context.Context
Path types.UniquePath
// Image is the container image to run
Image string
// Container function will be killed after this timeour.
// The default value is 5 minutes.
Timeout time.Duration
Perm ContainerFnPermission
// UIDGID is the os User ID and Group ID that will be
// used to run the container in format userId:groupId.
// If it's empty, "nobody" will be used.
UIDGID string
// StorageMounts are the storage or directories to mount
// into the container
StorageMounts []runtimeutil.StorageMount
// Env is a slice of env string that will be exposed to container
Env []string
}
ContainerFn implements a KRMFn which run a containerized KRM function
type ContainerFnPermission ¶
ContainerFnPermission contains the permission of container function such as network access.
type ExecFn ¶
type FunctionRunner ¶
type FunctionRunner struct {
// contains filtered or unexported fields
}
FunctionRunner wraps FunctionFilter and implements kio.Filter interface.
Click to show internal directories.
Click to hide internal directories.