plugin

package

Go to main page

Versions in this module

v1

v1.6.1

Dec 11, 2025

v1.6.0

Dec 11, 2025

Changes in this version

+ const DSPlugin_GetManifest_FullMethodName

type DSPluginClient

+ GetManifest func(ctx context.Context, in *GetManifestRequest, opts ...grpc.CallOption) (*GetManifestResponse, error)

type DSPluginServer

+ GetManifest func(context.Context, *GetManifestRequest) (*GetManifestResponse, error)

type GRPCClient

+ func (m *GRPCClient) GetManifest(ctx context.Context) (*types.PluginInfo, error)

type GRPCServer

+ func (m *GRPCServer) GetManifest(ctx context.Context, req *GetManifestRequest) (*GetManifestResponse, error)

+ type GetManifestRequest struct

+ func (*GetManifestRequest) Descriptor() ([]byte, []int)

+ func (*GetManifestRequest) ProtoMessage()

+ func (x *GetManifestRequest) ProtoReflect() protoreflect.Message

+ func (x *GetManifestRequest) Reset()

+ func (x *GetManifestRequest) String() string

+ type GetManifestResponse struct

+ Annotations map[string]string

+ Commands []*PluginCommand

+ Description string

+ Name string

+ Platform *Platform

+ Version string

+ func (*GetManifestResponse) Descriptor() ([]byte, []int)

+ func (*GetManifestResponse) ProtoMessage()

+ func (x *GetManifestResponse) GetAnnotations() map[string]string

+ func (x *GetManifestResponse) GetCommands() []*PluginCommand

+ func (x *GetManifestResponse) GetDescription() string

+ func (x *GetManifestResponse) GetName() string

+ func (x *GetManifestResponse) GetPlatform() *Platform

+ func (x *GetManifestResponse) GetVersion() string

+ func (x *GetManifestResponse) ProtoReflect() protoreflect.Message

+ func (x *GetManifestResponse) Reset()

+ func (x *GetManifestResponse) String() string

+ type PluginCommand struct

+ Description string

+ Name string

+ func (*PluginCommand) Descriptor() ([]byte, []int)

+ func (*PluginCommand) ProtoMessage()

+ func (x *PluginCommand) GetDescription() string

+ func (x *PluginCommand) GetName() string

+ func (x *PluginCommand) ProtoReflect() protoreflect.Message

+ func (x *PluginCommand) Reset()

+ func (x *PluginCommand) String() string

type UnimplementedDSPluginServer

+ func (UnimplementedDSPluginServer) GetManifest(context.Context, *GetManifestRequest) (*GetManifestResponse, error)

v1.5.0

Dec 10, 2025

Changes in this version

type ExecuteResponse

+ Finalizers []*FinalizerRequest

+ func (x *ExecuteResponse) GetFinalizers() []*FinalizerRequest

+ type FinalizerRequest struct

+ Args []string

+ Name string

+ Operation string

+ func (*FinalizerRequest) Descriptor() ([]byte, []int)

+ func (*FinalizerRequest) ProtoMessage()

+ func (x *FinalizerRequest) GetArgs() []string

+ func (x *FinalizerRequest) GetName() string

+ func (x *FinalizerRequest) GetOperation() string

+ func (x *FinalizerRequest) ProtoReflect() protoreflect.Message

+ func (x *FinalizerRequest) Reset()

+ func (x *FinalizerRequest) String() string

v1.4.0

Dec 9, 2025

v1.3.1

Dec 9, 2025

v1.3.0

Dec 8, 2025

Changes in this version

+ const HostConfig_GetEffectiveConfig_FullMethodName

+ var File_pkg_plugin_plugin_proto protoreflect.FileDescriptor

+ var HostConfig_ServiceDesc = grpc.ServiceDesc

+ func RegisterHostConfigServer(s grpc.ServiceRegistrar, srv HostConfigServer)

type ExecuteRequest

+ HostConfigBrokerId uint32

+ func (x *ExecuteRequest) GetHostConfigBrokerId() uint32

+ type GetEffectiveConfigRequest struct

+ func (*GetEffectiveConfigRequest) Descriptor() ([]byte, []int)

+ func (*GetEffectiveConfigRequest) ProtoMessage()

+ func (x *GetEffectiveConfigRequest) ProtoReflect() protoreflect.Message

+ func (x *GetEffectiveConfigRequest) Reset()

+ func (x *GetEffectiveConfigRequest) String() string

+ type GetEffectiveConfigResponse struct

+ ConfigJson []byte

+ func (*GetEffectiveConfigResponse) Descriptor() ([]byte, []int)

+ func (*GetEffectiveConfigResponse) ProtoMessage()

+ func (x *GetEffectiveConfigResponse) GetConfigJson() []byte

+ func (x *GetEffectiveConfigResponse) ProtoReflect() protoreflect.Message

+ func (x *GetEffectiveConfigResponse) Reset()

+ func (x *GetEffectiveConfigResponse) String() string

+ type HostConfigClient interface

+ GetEffectiveConfig func(ctx context.Context, in *GetEffectiveConfigRequest, opts ...grpc.CallOption) (*GetEffectiveConfigResponse, error)

+ func NewHostConfigClient(cc grpc.ClientConnInterface) HostConfigClient

+ type HostConfigServer interface

+ GetEffectiveConfig func(context.Context, *GetEffectiveConfigRequest) (*GetEffectiveConfigResponse, error)

+ type UnimplementedHostConfigServer struct

+ func (UnimplementedHostConfigServer) GetEffectiveConfig(context.Context, *GetEffectiveConfigRequest) (*GetEffectiveConfigResponse, error)

+ type UnsafeHostConfigServer interface

v1.2.2

Dec 8, 2025

v1.2.1

Dec 7, 2025

v1.2.0

Dec 7, 2025

v1.1.0

Nov 26, 2025

Changes in this version

+ const DSPlugin_Execute_FullMethodName

+ const DSPlugin_GetMetadata_FullMethodName

+ const DSPlugin_GetSchema_FullMethodName

+ const DSPlugin_ValidateConfig_FullMethodName

+ var DSPlugin_ServiceDesc = grpc.ServiceDesc

+ var File_plugin_proto protoreflect.FileDescriptor

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ func RegisterDSPluginServer(s grpc.ServiceRegistrar, srv DSPluginServer)

+ type DSPlugin struct

+ Impl types.PluginProtocol

+ func (p *DSPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *DSPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

+ type DSPluginClient interface

+ Execute func(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)

+ GetMetadata func(ctx context.Context, in *GetMetadataRequest, opts ...grpc.CallOption) (*GetMetadataResponse, error)

+ GetSchema func(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)

+ ValidateConfig func(ctx context.Context, in *ValidateConfigRequest, opts ...grpc.CallOption) (*ValidateConfigResponse, error)

+ func NewDSPluginClient(cc grpc.ClientConnInterface) DSPluginClient

+ type DSPluginServer interface

+ Execute func(context.Context, *ExecuteRequest) (*ExecuteResponse, error)

+ GetMetadata func(context.Context, *GetMetadataRequest) (*GetMetadataResponse, error)

+ GetSchema func(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)

+ ValidateConfig func(context.Context, *ValidateConfigRequest) (*ValidateConfigResponse, error)

+ type ExecuteRequest struct

+ Args []string

+ Env map[string]string

+ Operation string

+ func (*ExecuteRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteRequest) ProtoMessage()

+ func (x *ExecuteRequest) GetArgs() []string

+ func (x *ExecuteRequest) GetEnv() map[string]string

+ func (x *ExecuteRequest) GetOperation() string

+ func (x *ExecuteRequest) ProtoReflect() protoreflect.Message

+ func (x *ExecuteRequest) Reset()

+ func (x *ExecuteRequest) String() string

+ type ExecuteResponse struct

+ Error string

+ ExitCode int32

+ Stderr string

+ Stdout string

+ func (*ExecuteResponse) Descriptor() ([]byte, []int)

+ func (*ExecuteResponse) ProtoMessage()

+ func (x *ExecuteResponse) GetError() string

+ func (x *ExecuteResponse) GetExitCode() int32

+ func (x *ExecuteResponse) GetStderr() string

+ func (x *ExecuteResponse) GetStdout() string

+ func (x *ExecuteResponse) ProtoReflect() protoreflect.Message

+ func (x *ExecuteResponse) Reset()

+ func (x *ExecuteResponse) String() string

+ type GRPCClient struct

+ func (m *GRPCClient) Execute(ctx context.Context, operation string, args []string, env map[string]string) (*types.ExecutionResult, error)

+ func (m *GRPCClient) GetMetadata(ctx context.Context) (*types.PluginMetadata, error)

+ func (m *GRPCClient) GetSchema(ctx context.Context) (*types.PluginSchema, error)

+ func (m *GRPCClient) ValidateConfig(ctx context.Context, config map[string]interface{}) error

+ type GRPCServer struct

+ Impl types.PluginProtocol

+ func (m *GRPCServer) Execute(ctx context.Context, req *ExecuteRequest) (*ExecuteResponse, error)

+ func (m *GRPCServer) GetMetadata(ctx context.Context, req *GetMetadataRequest) (*GetMetadataResponse, error)

+ func (m *GRPCServer) GetSchema(ctx context.Context, req *GetSchemaRequest) (*GetSchemaResponse, error)

+ func (m *GRPCServer) ValidateConfig(ctx context.Context, req *ValidateConfigRequest) (*ValidateConfigResponse, error)

+ type GetMetadataRequest struct

+ func (*GetMetadataRequest) Descriptor() ([]byte, []int)

+ func (*GetMetadataRequest) ProtoMessage()

+ func (x *GetMetadataRequest) ProtoReflect() protoreflect.Message

+ func (x *GetMetadataRequest) Reset()

+ func (x *GetMetadataRequest) String() string

+ type GetMetadataResponse struct

+ Config map[string]string

+ Description string

+ Name string

+ Operations []string

+ Platform *Platform

+ Version string

+ func (*GetMetadataResponse) Descriptor() ([]byte, []int)

+ func (*GetMetadataResponse) ProtoMessage()

+ func (x *GetMetadataResponse) GetConfig() map[string]string

+ func (x *GetMetadataResponse) GetDescription() string

+ func (x *GetMetadataResponse) GetName() string

+ func (x *GetMetadataResponse) GetOperations() []string

+ func (x *GetMetadataResponse) GetPlatform() *Platform

+ func (x *GetMetadataResponse) GetVersion() string

+ func (x *GetMetadataResponse) ProtoReflect() protoreflect.Message

+ func (x *GetMetadataResponse) Reset()

+ func (x *GetMetadataResponse) String() string

+ type GetSchemaRequest struct

+ func (*GetSchemaRequest) Descriptor() ([]byte, []int)

+ func (*GetSchemaRequest) ProtoMessage()

+ func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSchemaRequest) Reset()

+ func (x *GetSchemaRequest) String() string

+ type GetSchemaResponse struct

+ Properties map[string]*SchemaProperty

+ Version string

+ func (*GetSchemaResponse) Descriptor() ([]byte, []int)

+ func (*GetSchemaResponse) ProtoMessage()

+ func (x *GetSchemaResponse) GetProperties() map[string]*SchemaProperty

+ func (x *GetSchemaResponse) GetVersion() string

+ func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSchemaResponse) Reset()

+ func (x *GetSchemaResponse) String() string

+ type Platform struct

+ Arch []string

+ Os []string

+ func (*Platform) Descriptor() ([]byte, []int)

+ func (*Platform) ProtoMessage()

+ func (x *Platform) GetArch() []string

+ func (x *Platform) GetOs() []string

+ func (x *Platform) ProtoReflect() protoreflect.Message

+ func (x *Platform) Reset()

+ func (x *Platform) String() string

+ type SchemaProperty struct

+ Default string

+ Description string

+ Required bool

+ Type string

+ func (*SchemaProperty) Descriptor() ([]byte, []int)

+ func (*SchemaProperty) ProtoMessage()

+ func (x *SchemaProperty) GetDefault() string

+ func (x *SchemaProperty) GetDescription() string

+ func (x *SchemaProperty) GetRequired() bool

+ func (x *SchemaProperty) GetType() string

+ func (x *SchemaProperty) ProtoReflect() protoreflect.Message

+ func (x *SchemaProperty) Reset()

+ func (x *SchemaProperty) String() string

+ type UnimplementedDSPluginServer struct

+ func (UnimplementedDSPluginServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)

+ func (UnimplementedDSPluginServer) GetMetadata(context.Context, *GetMetadataRequest) (*GetMetadataResponse, error)

+ func (UnimplementedDSPluginServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)

+ func (UnimplementedDSPluginServer) ValidateConfig(context.Context, *ValidateConfigRequest) (*ValidateConfigResponse, error)

+ type UnsafeDSPluginServer interface

+ type ValidateConfigRequest struct

+ Config map[string]string

+ func (*ValidateConfigRequest) Descriptor() ([]byte, []int)

+ func (*ValidateConfigRequest) ProtoMessage()

+ func (x *ValidateConfigRequest) GetConfig() map[string]string

+ func (x *ValidateConfigRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateConfigRequest) Reset()

+ func (x *ValidateConfigRequest) String() string

+ type ValidateConfigResponse struct

+ Error string

+ Valid bool

+ func (*ValidateConfigResponse) Descriptor() ([]byte, []int)

+ func (*ValidateConfigResponse) ProtoMessage()

+ func (x *ValidateConfigResponse) GetError() string

+ func (x *ValidateConfigResponse) GetValid() bool

+ func (x *ValidateConfigResponse) ProtoReflect() protoreflect.Message

+ func (x *ValidateConfigResponse) Reset()

+ func (x *ValidateConfigResponse) String() string

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