internal

package
v1.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 13, 2026 License: Apache-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ImageJoin added in v1.6.0

func ImageJoin(prefix, image string) string

func NewMultiEvaluator

func NewMultiEvaluator(evaluators ...Evaluator) pb.FunctionEvaluatorServer

func NewPodInfo

func NewPodInfo(firstResponseCh chan<- *connectionResponse) functionPodInfo

Types

type DockerConfig

type DockerConfig struct {
	Auths map[string]authn.AuthConfig `json:"auths"`
}

DockerConfig represents the structure of Docker config.json

type Evaluator

type Evaluator interface {
	EvaluateFunction(context.Context, *pb.EvaluateFunctionRequest) (*pb.EvaluateFunctionResponse, error)
}

func NewExecutableEvaluator

func NewExecutableEvaluator(FunctionConfigStore *reconciler.FunctionConfigStore) (Evaluator, error)

func NewPodEvaluator

func NewPodEvaluator(ctx context.Context, o PodEvaluatorOptions, cl client.Client, functionConfigStore *fnconf.FunctionConfigStore) (Evaluator, error)

type ExecutableEvaluatorOptions

type ExecutableEvaluatorOptions struct {
	FunctionCacheDir string // Path to cached functions
}

type PodEvaluatorOptions

type PodEvaluatorOptions struct {
	PodNamespace               string        // Namespace to run KRM functions pods in
	WrapperServerImage         string        // Container image name of the wrapper server
	GcScanInterval             time.Duration // Time interval between Garbage Collector scans
	PodTTL                     time.Duration // Time-to-live for pods before GC
	WarmUpPodCacheOnStartup    bool          // If true, pod-cache-config image pods will be deployed at startup
	EnablePrivateRegistries    bool          // If true enables the use of private registries and their authentication
	RegistryAuthSecretPath     string        // The path of the secret used for authenticating to custom registries
	RegistryAuthSecretName     string        // The name of the secret used for authenticating to custom registries
	EnablePrivateRegistriesTls bool          // If enabled, will prioritize use of user provided TLS secret when accessing registries
	TlsSecretPath              string        // The path of the secret used in tls configuration
	MaxGrpcMessageSize         int           // Maximum size of grpc messages in bytes
	DefaultImagePrefix         string        // Default image prefix to use when no prefix is given for an image
	MaxWaitlistLength          int           // Maximum waitlist length per pod
	MaxParallelPodsPerFunction int           // Maximum parallel pods per function
	MaxGrpcRetries             int           // Maximum number of retries on gRPC Unavailable errors
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL