Versions in this module Expand all Collapse all v0 v0.3.0 Sep 1, 2026 Changes in this version + type CommandOCISignatureVerifier struct + Path string + func (verifier CommandOCISignatureVerifier) Verify(ctx context.Context, reference, digest string) error + type DescriptorLoadTarget interface + RegisterVerbDescriptor func(VerbSpec, ExecutorDescriptor) error + type ExecutorDescriptor struct + Config map[string]interface{} + Type string + VerbName string + type ExtensionManager struct + func NewExtensionManager() *ExtensionManager + func (em *ExtensionManager) AddLoader(loader Loader) + func (em *ExtensionManager) GetLoaders() []Loader + func (em *ExtensionManager) LoadExtensions(ctx context.Context, target LoadTarget) error + func (manager *ExtensionManager) Stage(ctx context.Context, options StageOptions) (*ExtensionSnapshot, error) + type ExtensionSnapshot struct + func NewResourceSnapshot(closers ...io.Closer) (*ExtensionSnapshot, error) + func (snapshot *ExtensionSnapshot) Acquire() (*ExtensionSnapshotHandle, error) + func (snapshot *ExtensionSnapshot) AttachCloser(closer io.Closer) error + func (snapshot *ExtensionSnapshot) Closed() bool + func (snapshot *ExtensionSnapshot) Load(ctx context.Context, target LoadTarget) error + func (snapshot *ExtensionSnapshot) Name() string + func (snapshot *ExtensionSnapshot) Retire() error + type ExtensionSnapshotHandle struct + func (handle *ExtensionSnapshotHandle) Release() error + func (handle *ExtensionSnapshotHandle) Snapshot() *ExtensionSnapshot + type ExtensionSnapshotManager struct + func (manager *ExtensionSnapshotManager) Acquire() (*ExtensionSnapshotHandle, error) + func (manager *ExtensionSnapshotManager) Close() error + func (manager *ExtensionSnapshotManager) Publish(snapshot *ExtensionSnapshot) error + type FunctionDef struct + Config map[string]interface{} + Description string + Name string + Type string + type GRPCExecutor struct + Address string + Insecure bool + Metadata map[string]string + Method string + ServerName string + Timeout time.Duration + UseTLS bool + func NewGRPCExecutor(config map[string]interface{}) (*GRPCExecutor, error) + func (ge *GRPCExecutor) Close() error + func (ge *GRPCExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error) + func (ge *GRPCExecutor) InvocationResolverDescriptor() any + func (ge *GRPCExecutor) Invoke(ctx context.Context, request invocation.Request) invocation.Outcome + func (ge *GRPCExecutor) SourceInfo() verb.SourceInfo + type HTTPExecutor struct + Headers map[string]string + Method string + Policy OutboundNetworkPolicy + Timeout time.Duration + URL string + func NewHTTPExecutor(config map[string]interface{}) (*HTTPExecutor, error) + func (he *HTTPExecutor) Close() error + func (he *HTTPExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error) + func (he *HTTPExecutor) InvocationResolverDescriptor() any + func (he *HTTPExecutor) Invoke(ctx context.Context, request invocation.Request) invocation.Outcome + func (he *HTTPExecutor) SourceInfo() verb.SourceInfo + type IPResolver interface + LookupIPAddr func(context.Context, string) ([]net.IPAddr, error) + type JSONResourceSpec struct + Capabilities []string + Resource string + func (jrs *JSONResourceSpec) GetCapabilities() []string + func (jrs *JSONResourceSpec) GetResource() string + type JSONSchemaLoader struct + func NewJSONSchemaLoader(name, filePath string) *JSONSchemaLoader + func (jsl *JSONSchemaLoader) Load(ctx context.Context, target LoadTarget) error + func (jsl *JSONSchemaLoader) Name() string + type JSONVerbLoader struct + func NewJSONVerbLoader(name, filePath string) *JSONVerbLoader + func (jvl *JSONVerbLoader) Load(ctx context.Context, target LoadTarget) error + func (jvl *JSONVerbLoader) Name() string + type JSONVerbSpec struct + ArgTypes map[string]string + Capabilities []string + Description string + InverseVerb string + Name string + RequiredArgs []string + Resources []JSONResourceSpec + ReturnType string + Target *VerbTarget + func (jvs *JSONVerbSpec) GetArgTypes() map[string]string + func (jvs *JSONVerbSpec) GetCapabilities() []string + func (jvs *JSONVerbSpec) GetDescription() string + func (jvs *JSONVerbSpec) GetInverseVerb() string + func (jvs *JSONVerbSpec) GetName() string + func (jvs *JSONVerbSpec) GetRequiredArgs() []string + func (jvs *JSONVerbSpec) GetResources() []ResourceSpec + func (jvs *JSONVerbSpec) GetReturnType() string + type LoadTarget interface + LoadData func(path string, value interface{}) error + RegisterFunction func(name string, fn interface{}) error + RegisterType func(name string, typeDef TypeDefinition) error + RegisterVerb func(spec VerbSpec, executor VerbExecutor) error + type Loader interface + Load func(ctx context.Context, target LoadTarget) error + Name func() string + func LoadExtensionsFromReader(r io.Reader, extension string) (Loader, error) + func LoadFromDirectory(dirPath string) ([]Loader, error) + type MockExecutor struct + Name string + func (me *MockExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error) + func (me *MockExecutor) SourceInfo() verb.SourceInfo + type NoOpExecutor struct + func (noe *NoOpExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error) + func (noe *NoOpExecutor) SourceInfo() verb.SourceInfo + type OCIBundleLoader struct + func NewOCIBundleLoader(name, ref string) *OCIBundleLoader + func NewOCIBundleLoaderWithPolicy(name, ref string, policy OCIVerificationPolicy) *OCIBundleLoader + func (obl *OCIBundleLoader) Load(ctx context.Context, target LoadTarget) error + func (obl *OCIBundleLoader) Name() string + type OCIExecutor struct + func NewOCIExecutor(verbName string, config map[string]interface{}) (*OCIExecutor, error) + func (oe *OCIExecutor) Close() error + func (oe *OCIExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error) + func (oe *OCIExecutor) InvocationResolverDescriptor() any + func (oe *OCIExecutor) Invoke(ctx context.Context, request invocation.Request) invocation.Outcome + func (oe *OCIExecutor) SourceInfo() verb.SourceInfo + func (oe *OCIExecutor) Warmup(ctx context.Context) error + type OCISignatureVerifier interface + Verify func(context.Context, string, string) error + type OCIVerificationPolicy struct + RequireSignature bool + Verifier OCISignatureVerifier + type OutboundNetworkPolicy struct + AllowPrivate bool + DialTimeout time.Duration + MaxRedirects int + Resolver IPResolver + func (policy OutboundNetworkPolicy) HTTPClient(timeout time.Duration, sensitiveHeaders map[string]string) *http.Client + func (policy OutboundNetworkPolicy) ValidateURL(raw string) (*url.URL, error) + type ProtoSchemaLoader struct + func NewProtoSchemaLoader(name string, message proto.Message) *ProtoSchemaLoader + func (psl *ProtoSchemaLoader) Load(ctx context.Context, target LoadTarget) error + func (psl *ProtoSchemaLoader) Name() string + type ProtoVerbLoader struct + func NewProtoVerbLoader(name string, message proto.Message) *ProtoVerbLoader + func (pvl *ProtoVerbLoader) Load(ctx context.Context, target LoadTarget) error + func (pvl *ProtoVerbLoader) Name() string + type ResourceSpec interface + GetCapabilities func() []string + GetResource func() string + type SchemaManifest struct + Description string + Functions map[string]FunctionDef + InitialData map[string]interface{} + Name string + Types map[string]TypeDefinition + Version string + type SourceFile struct + Data []byte + Path string + type SourceLoadTarget interface + RegisterSource func(SourceFile) error + type StageOptions struct + MaxDataEntries int + MaxFunctions int + MaxLoaders int + MaxSourceBytes int + MaxSources int + MaxTotalBytes int + MaxTypes int + MaxVerbs int + Timeout time.Duration + type StaticSchemaLoader struct + func NewStaticSchemaLoader(name string) *StaticSchemaLoader + func (ssl *StaticSchemaLoader) AddData(path string, value interface{}) *StaticSchemaLoader + func (ssl *StaticSchemaLoader) AddFunction(name string, fn interface{}) *StaticSchemaLoader + func (ssl *StaticSchemaLoader) AddType(name string, typeDef TypeDefinition) *StaticSchemaLoader + func (ssl *StaticSchemaLoader) Load(ctx context.Context, target LoadTarget) error + func (ssl *StaticSchemaLoader) Name() string + type StaticSourceLoader struct + func NewStaticSourceLoader(name, path string, data []byte) *StaticSourceLoader + func (loader *StaticSourceLoader) Load(_ context.Context, target LoadTarget) error + func (loader *StaticSourceLoader) Name() string + type StaticVerbLoader struct + func NewStaticVerbLoader(name string, verbs []VerbDefinition) *StaticVerbLoader + func (svl *StaticVerbLoader) Load(ctx context.Context, target LoadTarget) error + func (svl *StaticVerbLoader) Name() string + type StreamExecutor struct + func NewStreamExecutor(config map[string]interface{}) (*StreamExecutor, error) + func (se *StreamExecutor) Close() error + func (se *StreamExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error) + func (se *StreamExecutor) InvocationResolverDescriptor() any + func (se *StreamExecutor) Invoke(ctx context.Context, request invocation.Request) invocation.Outcome + func (se *StreamExecutor) SourceInfo() verb.SourceInfo + type TypeDefinition struct + Description string + Name string + Properties interface{} + Required []string + Type string + type VerbDefinition struct + Executor VerbExecutor + Spec VerbSpec + type VerbExecutor = verb.Executor + type VerbManifest struct + Description string + Executors map[string]interface{} + Name string + Verbs []JSONVerbSpec + Version string + type VerbSpec interface + GetArgTypes func() map[string]string + GetCapabilities func() []string + GetDescription func() string + GetInverseVerb func() string + GetName func() string + GetRequiredArgs func() []string + GetResources func() []ResourceSpec + GetReturnType func() string + type VerbTarget struct + Config map[string]interface{} + Ref string + Type string
Go to main page