space_exec

package

Go to main page

Versions in this module

v0

v0.51.6

May 11, 2026

v0.51.5

May 10, 2026

v0.51.4

May 9, 2026

v0.51.3

May 9, 2026

v0.51.2

May 7, 2026

Changes in this version

type SRPCPluginExecServiceClient

+ ExecuteStream func(ctx context.Context, in *PluginExecRequest) (SRPCPluginExecService_ExecuteStreamClient, error)

type SRPCPluginExecServiceHandler

+ func (SRPCPluginExecServiceHandler) InvokeMethod_ExecuteStream(impl SRPCPluginExecServiceServer, strm srpc.Stream) error

type SRPCPluginExecServiceServer

+ ExecuteStream func(*PluginExecRequest, SRPCPluginExecService_ExecuteStreamStream) error

+ type SRPCPluginExecService_ExecuteStreamClient interface

+ Recv func() (*PluginExecResponse, error)

+ RecvTo func(*PluginExecResponse) error

+ type SRPCPluginExecService_ExecuteStreamStream interface

+ Send func(*PluginExecResponse) error

+ SendAndClose func(*PluginExecResponse) error

v0.51.0

May 1, 2026

Changes in this version

+ const PluginExecConfigID

+ const SRPCPluginExecServiceServiceID

+ func NewSRPCPluginExecServiceHandler(impl SRPCPluginExecServiceServer, serviceID string) srpc.Handler

+ func RegisterPluginExec(r *Registry, b bus.Bus)

+ func SRPCRegisterPluginExecService(mux srpc.Mux, impl SRPCPluginExecServiceServer) error

type HandlerFactory

+ func NewPluginExecHandler(b bus.Bus) HandlerFactory

+ type PluginExecConfig struct

+ ControllerConfig []byte

+ ControllerId string

+ PluginId string

+ func (*PluginExecConfig) ProtoMessage()

+ func (c *PluginExecConfig) EqualsConfig(other config.Config) bool

+ func (c *PluginExecConfig) GetConfigID() string

+ func (c *PluginExecConfig) MarshalBlock() ([]byte, error)

+ func (c *PluginExecConfig) UnmarshalBlock(data []byte) error

+ func (c *PluginExecConfig) Validate() error

+ func (m *PluginExecConfig) CloneMessageVT() protobuf_go_lite.CloneMessage

+ func (m *PluginExecConfig) CloneVT() *PluginExecConfig

+ func (m *PluginExecConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PluginExecConfig) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PluginExecConfig) MarshalVT() (dAtA []byte, err error)

+ func (m *PluginExecConfig) SizeVT() (n int)

+ func (m *PluginExecConfig) UnmarshalVT(dAtA []byte) error

+ func (this *PluginExecConfig) EqualMessageVT(thatMsg any) bool

+ func (this *PluginExecConfig) EqualVT(that *PluginExecConfig) bool

+ func (x *PluginExecConfig) GetControllerConfig() []byte

+ func (x *PluginExecConfig) GetControllerId() string

+ func (x *PluginExecConfig) GetPluginId() string

+ func (x *PluginExecConfig) MarshalJSON() ([]byte, error)

+ func (x *PluginExecConfig) MarshalProtoJSON(s *json.MarshalState)

+ func (x *PluginExecConfig) MarshalProtoText() string

+ func (x *PluginExecConfig) Reset()

+ func (x *PluginExecConfig) String() string

+ func (x *PluginExecConfig) UnmarshalJSON(b []byte) error

+ func (x *PluginExecConfig) UnmarshalProtoJSON(s *json.UnmarshalState)

+ type PluginExecLog struct

+ Level string

+ Message string

+ func (*PluginExecLog) ProtoMessage()

+ func (m *PluginExecLog) CloneMessageVT() protobuf_go_lite.CloneMessage

+ func (m *PluginExecLog) CloneVT() *PluginExecLog

+ func (m *PluginExecLog) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PluginExecLog) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PluginExecLog) MarshalVT() (dAtA []byte, err error)

+ func (m *PluginExecLog) SizeVT() (n int)

+ func (m *PluginExecLog) UnmarshalVT(dAtA []byte) error

+ func (this *PluginExecLog) EqualMessageVT(thatMsg any) bool

+ func (this *PluginExecLog) EqualVT(that *PluginExecLog) bool

+ func (x *PluginExecLog) GetLevel() string

+ func (x *PluginExecLog) GetMessage() string

+ func (x *PluginExecLog) MarshalJSON() ([]byte, error)

+ func (x *PluginExecLog) MarshalProtoJSON(s *json.MarshalState)

+ func (x *PluginExecLog) MarshalProtoText() string

+ func (x *PluginExecLog) Reset()

+ func (x *PluginExecLog) String() string

+ func (x *PluginExecLog) UnmarshalJSON(b []byte) error

+ func (x *PluginExecLog) UnmarshalProtoJSON(s *json.UnmarshalState)

+ type PluginExecOutputFile struct

+ Data []byte

+ Path string

+ func (*PluginExecOutputFile) ProtoMessage()

+ func (m *PluginExecOutputFile) CloneMessageVT() protobuf_go_lite.CloneMessage

+ func (m *PluginExecOutputFile) CloneVT() *PluginExecOutputFile

+ func (m *PluginExecOutputFile) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PluginExecOutputFile) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PluginExecOutputFile) MarshalVT() (dAtA []byte, err error)

+ func (m *PluginExecOutputFile) SizeVT() (n int)

+ func (m *PluginExecOutputFile) UnmarshalVT(dAtA []byte) error

+ func (this *PluginExecOutputFile) EqualMessageVT(thatMsg any) bool

+ func (this *PluginExecOutputFile) EqualVT(that *PluginExecOutputFile) bool

+ func (x *PluginExecOutputFile) GetData() []byte

+ func (x *PluginExecOutputFile) GetPath() string

+ func (x *PluginExecOutputFile) MarshalJSON() ([]byte, error)

+ func (x *PluginExecOutputFile) MarshalProtoJSON(s *json.MarshalState)

+ func (x *PluginExecOutputFile) MarshalProtoText() string

+ func (x *PluginExecOutputFile) Reset()

+ func (x *PluginExecOutputFile) String() string

+ func (x *PluginExecOutputFile) UnmarshalJSON(b []byte) error

+ func (x *PluginExecOutputFile) UnmarshalProtoJSON(s *json.UnmarshalState)

+ type PluginExecRequest struct

+ ControllerConfig []byte

+ ControllerId string

+ Inputs []*value.Value

+ func (*PluginExecRequest) ProtoMessage()

+ func (m *PluginExecRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

+ func (m *PluginExecRequest) CloneVT() *PluginExecRequest

+ func (m *PluginExecRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PluginExecRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PluginExecRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PluginExecRequest) SizeVT() (n int)

+ func (m *PluginExecRequest) UnmarshalVT(dAtA []byte) error

+ func (this *PluginExecRequest) EqualMessageVT(thatMsg any) bool

+ func (this *PluginExecRequest) EqualVT(that *PluginExecRequest) bool

+ func (x *PluginExecRequest) GetControllerConfig() []byte

+ func (x *PluginExecRequest) GetControllerId() string

+ func (x *PluginExecRequest) GetInputs() []*value.Value

+ func (x *PluginExecRequest) MarshalJSON() ([]byte, error)

+ func (x *PluginExecRequest) MarshalProtoJSON(s *json.MarshalState)

+ func (x *PluginExecRequest) MarshalProtoText() string

+ func (x *PluginExecRequest) Reset()

+ func (x *PluginExecRequest) String() string

+ func (x *PluginExecRequest) UnmarshalJSON(b []byte) error

+ func (x *PluginExecRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

+ type PluginExecResponse struct

+ Error string

+ Logs []*PluginExecLog

+ OutputFiles []*PluginExecOutputFile

+ Outputs []*value.Value

+ func (*PluginExecResponse) ProtoMessage()

+ func (m *PluginExecResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

+ func (m *PluginExecResponse) CloneVT() *PluginExecResponse

+ func (m *PluginExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PluginExecResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PluginExecResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *PluginExecResponse) SizeVT() (n int)

+ func (m *PluginExecResponse) UnmarshalVT(dAtA []byte) error

+ func (this *PluginExecResponse) EqualMessageVT(thatMsg any) bool

+ func (this *PluginExecResponse) EqualVT(that *PluginExecResponse) bool

+ func (x *PluginExecResponse) GetError() string

+ func (x *PluginExecResponse) GetLogs() []*PluginExecLog

+ func (x *PluginExecResponse) GetOutputFiles() []*PluginExecOutputFile

+ func (x *PluginExecResponse) GetOutputs() []*value.Value

+ func (x *PluginExecResponse) MarshalJSON() ([]byte, error)

+ func (x *PluginExecResponse) MarshalProtoJSON(s *json.MarshalState)

+ func (x *PluginExecResponse) MarshalProtoText() string

+ func (x *PluginExecResponse) Reset()

+ func (x *PluginExecResponse) String() string

+ func (x *PluginExecResponse) UnmarshalJSON(b []byte) error

+ func (x *PluginExecResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

type Registry

+ func NewDefaultRegistryWithBus(b bus.Bus) *Registry

+ type SRPCPluginExecServiceClient interface

+ Execute func(ctx context.Context, in *PluginExecRequest) (*PluginExecResponse, error)

+ SRPCClient func() srpc.Client

+ func NewSRPCPluginExecServiceClient(cc srpc.Client) SRPCPluginExecServiceClient

+ func NewSRPCPluginExecServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPluginExecServiceClient

+ type SRPCPluginExecServiceHandler struct

+ func (SRPCPluginExecServiceHandler) GetMethodIDs() []string

+ func (SRPCPluginExecServiceHandler) InvokeMethod_Execute(impl SRPCPluginExecServiceServer, strm srpc.Stream) error

+ func (d *SRPCPluginExecServiceHandler) GetServiceID() string

+ func (d *SRPCPluginExecServiceHandler) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)

+ type SRPCPluginExecServiceServer interface

+ Execute func(context.Context, *PluginExecRequest) (*PluginExecResponse, error)

+ type SRPCPluginExecService_ExecuteStream interface

v0.50.0

Apr 28, 2026

Changes in this version

+ const ExportZipConfigID

+ const FileHashConfigID

+ const NoopConfigID

+ const UnixfsReadConfigID

+ var ErrUnknownConfigID = errors.New("unknown exec handler config ID")

+ var GitCloneConfigID = forge_lib_git_clone.ConfigID

+ var KvtxConfigID = forge_lib_kvtx.ConfigID

+ func BridgeFactories(r *Registry) []controller.Factory

+ func NewNoopTarget() *forge_target.Target

+ func ProcessExecution(ctx context.Context, le *logrus.Entry, ws world.WorldState, registry *Registry, ...) error

+ func RegisterExportZip(r *Registry)

+ func RegisterFileHash(r *Registry)

+ func RegisterGitClone(r *Registry)

+ func RegisterKvtx(r *Registry)

+ func RegisterNoop(r *Registry)

+ func RegisterUnixfsRead(r *Registry)

+ type BridgeFactory struct

+ func NewBridgeFactory(configID string, registry *Registry) *BridgeFactory

+ func (f *BridgeFactory) Construct(ctx context.Context, conf config.Config, opts controller.ConstructOpts) (controller.Controller, error)

+ func (f *BridgeFactory) ConstructConfig() config.Config

+ func (f *BridgeFactory) GetConfigID() string

+ func (f *BridgeFactory) GetVersion() semver.Version

+ type Handler interface

+ Execute func(ctx context.Context) error

+ func NewExportZipHandler(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ func NewFileHashHandler(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ func NewGitCloneHandler(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ func NewKvtxHandler(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ func NewNoopHandler(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ func NewUnixfsReadHandler(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ type HandlerFactory func(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ type Registry struct

+ func NewDefaultRegistry() *Registry

+ func NewRegistry() *Registry

+ func (r *Registry) ConfigIDs() []string

+ func (r *Registry) CreateHandler(ctx context.Context, le *logrus.Entry, ws world.WorldState, ...) (Handler, error)

+ func (r *Registry) Lookup(configID string) HandlerFactory

+ func (r *Registry) Register(configID string, factory HandlerFactory)

+ type SpaceExecConfig struct

+ func NewSpaceExecConfig(configID string) *SpaceExecConfig

+ func (c *SpaceExecConfig) EqualsConfig(other config.Config) bool

+ func (c *SpaceExecConfig) GetConfigID() string

+ func (c *SpaceExecConfig) MarshalBlock() ([]byte, error)

+ func (c *SpaceExecConfig) MarshalJSON() ([]byte, error)

+ func (c *SpaceExecConfig) MarshalToSizedBufferVT(buf []byte) (int, error)

+ func (c *SpaceExecConfig) MarshalVT() ([]byte, error)

+ func (c *SpaceExecConfig) Reset()

+ func (c *SpaceExecConfig) SizeVT() int

+ func (c *SpaceExecConfig) UnmarshalBlock(data []byte) error

+ func (c *SpaceExecConfig) UnmarshalJSON(data []byte) error

+ func (c *SpaceExecConfig) UnmarshalVT(data []byte) error

+ func (c *SpaceExecConfig) Validate() error

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