Versions in this module Expand all Collapse all v0 v0.1.0 Sep 12, 2023 Changes in this version + var ErrExecutionCompleted = errors.New("execution completed") + var ErrNoMatchingRequest = errors.New("no matching request for given message id") + var ErrNoReplyMsgID = errors.New("no repliesTo set - cannot handle message") + func NewExecutorServiceServer(registry *modules.TypeRegistry) rpcv1connect.ExecutorServiceHandler + func NewHealthServer(logger *slog.Logger) healthv1connect.HealthHandler + type ContainerExecutionContext struct + func NewContainerExecutionContext(ctx context.Context, logger *slog.Logger, name, workingDir string, ...) *ContainerExecutionContext + func (c ContainerExecutionContext) BinariesDir() string + func (c ContainerExecutionContext) GetState(ctx context.Context, key string) ([]byte, state.Metadata, error) + func (c ContainerExecutionContext) Logger() *slog.Logger + func (c ContainerExecutionContext) Name() string + func (c ContainerExecutionContext) OutDir() string + func (c ContainerExecutionContext) SetState(ctx context.Context, key string, value []byte) error + func (c ContainerExecutionContext) StdErr() io.Writer + func (c ContainerExecutionContext) StdOut() io.Writer + func (c ContainerExecutionContext) WorkingDir() string + type ExecutorServiceServer struct + func (e *ExecutorServiceServer) ExecuteStream(ctx context.Context, ...) (err error) + type GrpcExecutorHandler struct + Level slog.Level + func NewGrpcExecutorHandler(sender StreamSender[*remotev1.ExecutionServerMessage]) *GrpcExecutorHandler + func (g GrpcExecutorHandler) Enabled(_ context.Context, level slog.Level) bool + func (g GrpcExecutorHandler) Handle(_ context.Context, record slog.Record) error + func (g GrpcExecutorHandler) WithAttrs(attrs []slog.Attr) slog.Handler + func (g GrpcExecutorHandler) WithGroup(name string) slog.Handler + type PluginManagerServiceServer struct + func (p PluginManagerServiceServer) RegisterPluginModule(_ context.Context, ...) (*connect.Response[remotev1.RegisterPluginModuleResponse], error) + type RemoteStateClient struct + func (c *RemoteStateClient) GetState(ctx context.Context, key string) ([]byte, state.Metadata, error) + func (c *RemoteStateClient) SetState(ctx context.Context, key string, value []byte) error + type RemoteTaskExecutor struct + func (e *RemoteTaskExecutor) Execute(ctx context.Context, startTask *remotev1.StartTaskRequest) (resp chan *remotev1.TaskResult, errs chan error) + type RequestResponseClient struct + func NewRequestResponseClient(logger *slog.Logger, sender StreamSender[*remotev1.ExecutionServerMessage]) *RequestResponseClient + func (rrc *RequestResponseClient) DispatchMessages(receiver StreamReceiver[*remotev1.ExecutionClientMessage]) (errs chan error) + func (rrc *RequestResponseClient) Send(ctx context.Context, req *remotev1.ExecutionServerMessage) (resp *remotev1.ExecutionClientMessage, err error) + type StreamReceiver interface + Receive func() (msg T, err error) + type StreamSender interface + Send func(msg T) error