reconciler

package

v1.6.0-pre1 Latest Latest Go to latest Published: Jun 25, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kptdev/porch

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type BinaryCacheEntry
type BuiltInCacheEntry
type FunctionConfigReconciler
- func (r *FunctionConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, finalErr error)
type FunctionConfigStore
- func NewFunctionConfigStore(defaultImagePrefix, defaultBinaryDir string) *FunctionConfigStore
type ReconcilerFor

Constants ¶

View Source

const BaseFinalizer = "config.porch.kpt.dev/functionconfig"

View Source

const ControllerFinalizer = BaseFinalizer + "-controller"

View Source

const FunctionRunnerFinalizer = BaseFinalizer + "-function-runner"

View Source

const ServerFinalizer = BaseFinalizer + "-porch-server"

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BinaryCacheEntry ¶

type BinaryCacheEntry struct {
	PrefixRegex string
	Tags        map[string]string
}

type BuiltInCacheEntry ¶

type BuiltInCacheEntry struct {
	PrefixRegex string
	Process     fnsdk.ResourceListProcessor
	Tags        []string
}

type FunctionConfigReconciler ¶

type FunctionConfigReconciler struct {
	Client              client.Client
	FunctionConfigStore *FunctionConfigStore
	// For indicates which component the reconciler is collecting the configs for
	// TODO: remove after merging of function-runner into server
	For ReconcilerFor
}

func (*FunctionConfigReconciler) Reconcile ¶

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

type FunctionConfigStore ¶

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

func NewFunctionConfigStore ¶

func NewFunctionConfigStore(defaultImagePrefix, defaultBinaryDir string) *FunctionConfigStore

func (*FunctionConfigStore) DeleteFunctionConfig ¶

func (s *FunctionConfigStore) DeleteFunctionConfig(key types.NamespacedName)

func (*FunctionConfigStore) GetBinaryFromCache ¶

func (s *FunctionConfigStore) GetBinaryFromCache(image string) (string, bool)

func (*FunctionConfigStore) GetBinaryFromCacheByConstraint ¶

func (s *FunctionConfigStore) GetBinaryFromCacheByConstraint(image, tag string) (string, bool)

func (*FunctionConfigStore) GetExecCache ¶

func (s *FunctionConfigStore) GetExecCache() map[string]BuiltInCacheEntry

func (*FunctionConfigStore) GetFunctionConfig ¶

func (s *FunctionConfigStore) GetFunctionConfig(name string) (*configapi.FunctionConfig, bool)

func (*FunctionConfigStore) GetProcessorFromCache ¶

func (s *FunctionConfigStore) GetProcessorFromCache(image string) (fnsdk.ResourceListProcessor, bool)

GetProcessorFromCache looks up a function processor by image, holding the read lock for the duration of the lookup.

func (*FunctionConfigStore) List ¶

func (s *FunctionConfigStore) List() []*configapi.FunctionConfig

func (*FunctionConfigStore) UpdateBinaryCache ¶

func (s *FunctionConfigStore) UpdateBinaryCache(_ string, obj *configapi.FunctionConfig)

func (*FunctionConfigStore) UpdateExecCache ¶

func (s *FunctionConfigStore) UpdateExecCache(name string, functionConfig *configapi.FunctionConfig)

func (*FunctionConfigStore) UpsertFunctionConfig ¶

func (s *FunctionConfigStore) UpsertFunctionConfig(name string, obj *configapi.FunctionConfig)

type ReconcilerFor ¶

type ReconcilerFor string

const (
	ReconcilerForFunctionRunner ReconcilerFor = "function-runner"
	ReconcilerForServer         ReconcilerFor = "server"
	ReconcilerForController     ReconcilerFor = "controller"
)

Source Files ¶

View all Source files

functionconfigreconciler.go

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