Documentation
¶
Index ¶
- Constants
- func NewWatcherManager() *watcherManager
- type CaDEngine
- type EngineOption
- func WithBuiltinFunctionRuntime(imagePrefix string) EngineOption
- func WithCache(cache cachetypes.Cache) EngineOption
- func WithCredentialResolver(resolver repository.CredentialResolver) EngineOption
- func WithFunctionRuntime(runtime fn.FunctionRuntime) EngineOption
- func WithGRPCFunctionRuntime(options GRPCRuntimeOptions) EngineOption
- func WithReferenceResolver(resolver repository.ReferenceResolver) EngineOption
- func WithRunnerOptions(options fnruntime.RunnerOptions) EngineOption
- func WithRunnerOptionsResolver(fn func(namespace string) fnruntime.RunnerOptions) EngineOption
- func WithSimpleFunctionRuntime() EngineOption
- func WithUserInfoProvider(provider repository.UserInfoProvider) EngineOption
- func WithWatcherManager(watcherManager *watcherManager) EngineOption
- type EngineOptionFunc
- type GRPCRuntimeOptions
- type ObjectWatcher
- type WatcherManager
Constants ¶
View Source
const (
OptimisticLockErrorMsg = "the object has been modified; please apply your changes to the latest version and try again"
)
Variables ¶
This section is empty.
Functions ¶
func NewWatcherManager ¶
func NewWatcherManager() *watcherManager
Types ¶
type CaDEngine ¶
type CaDEngine interface {
// ObjectCache() is a cache of all our objects.
ObjectCache() WatcherManager
UpdatePackageResources(ctx context.Context, repositoryObj *configapi.Repository, oldPackage repository.PackageRevision, old, new *api.PackageRevisionResources) (repository.PackageRevision, *api.RenderStatus, error)
ListPackageRevisions(ctx context.Context, repositorySpec *configapi.Repository, filter repository.ListPackageRevisionFilter) ([]repository.PackageRevision, error)
CreatePackageRevision(ctx context.Context, repositoryObj *configapi.Repository, obj *api.PackageRevision, parent repository.PackageRevision) (repository.PackageRevision, error)
UpdatePackageRevision(ctx context.Context, version int, repositoryObj *configapi.Repository, oldPackage repository.PackageRevision, old, new *api.PackageRevision, parent repository.PackageRevision) (repository.PackageRevision, error)
DeletePackageRevision(ctx context.Context, repositoryObj *configapi.Repository, obj repository.PackageRevision) error
ListPackages(ctx context.Context, repositorySpec *configapi.Repository, filter repository.ListPackageFilter) ([]repository.Package, error)
CreatePackage(ctx context.Context, repositoryObj *configapi.Repository, obj *api.PorchPackage) (repository.Package, error)
UpdatePackage(ctx context.Context, repositoryObj *configapi.Repository, oldPackage repository.Package, old, new *api.PorchPackage) (repository.Package, error)
DeletePackage(ctx context.Context, repositoryObj *configapi.Repository, obj repository.Package) error
}
func NewCaDEngine ¶
func NewCaDEngine(opts ...EngineOption) (CaDEngine, error)
type EngineOption ¶
type EngineOption interface {
// contains filtered or unexported methods
}
func WithBuiltinFunctionRuntime ¶
func WithBuiltinFunctionRuntime(imagePrefix string) EngineOption
func WithCache ¶
func WithCache(cache cachetypes.Cache) EngineOption
func WithCredentialResolver ¶
func WithCredentialResolver(resolver repository.CredentialResolver) EngineOption
func WithFunctionRuntime ¶
func WithFunctionRuntime(runtime fn.FunctionRuntime) EngineOption
func WithGRPCFunctionRuntime ¶
func WithGRPCFunctionRuntime(options GRPCRuntimeOptions) EngineOption
func WithReferenceResolver ¶
func WithReferenceResolver(resolver repository.ReferenceResolver) EngineOption
func WithRunnerOptions ¶
func WithRunnerOptions(options fnruntime.RunnerOptions) EngineOption
func WithRunnerOptionsResolver ¶
func WithRunnerOptionsResolver(fn func(namespace string) fnruntime.RunnerOptions) EngineOption
func WithSimpleFunctionRuntime ¶
func WithSimpleFunctionRuntime() EngineOption
func WithUserInfoProvider ¶
func WithUserInfoProvider(provider repository.UserInfoProvider) EngineOption
func WithWatcherManager ¶
func WithWatcherManager(watcherManager *watcherManager) EngineOption
type EngineOptionFunc ¶
type EngineOptionFunc func(engine *cadEngine) error
type GRPCRuntimeOptions ¶ added in v1.4.0
type ObjectWatcher ¶
type ObjectWatcher interface {
OnPackageRevisionChange(eventType watch.EventType, obj repository.PackageRevision) bool
}
PackageRevisionWatcher is the callback interface for watchers.
type WatcherManager ¶
type WatcherManager interface {
WatchPackageRevisions(ctx context.Context, filter repository.ListPackageRevisionFilter, callback ObjectWatcher) error
}
ObjectCache caches objects across repositories, and allows for watching.
Source Files
Click to show internal directories.
Click to hide internal directories.