v1

package

v0.1.0 Latest Latest Go to latest Published: Sep 12, 2023 License: MIT Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

code.icb4dc0.de/buildr/buildr

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewExecutorServiceServer(registry *modules.TypeRegistry) rpcv1connect.ExecutorServiceHandler
func NewHealthServer(logger *slog.Logger) healthv1connect.HealthHandler
type ContainerExecutionContext
- 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
- func (e *ExecutorServiceServer) ExecuteStream(ctx context.Context, ...) (err error)
type GrpcExecutorHandler
- 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
- func (p PluginManagerServiceServer) RegisterPluginModule(_ context.Context, ...) (*connect.Response[remotev1.RegisterPluginModuleResponse], error)
type RemoteStateClient
- 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
- func (e *RemoteTaskExecutor) Execute(ctx context.Context, startTask *remotev1.StartTaskRequest) (resp chan *remotev1.TaskResult, errs chan error)
type RequestResponseClient
- 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
type StreamSender

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNoReplyMsgID      = errors.New("no repliesTo set - cannot handle message")
	ErrNoMatchingRequest = errors.New("no matching request for given message id")
)

View Source

var (
	ErrExecutionCompleted = errors.New("execution completed")
)

Functions ¶

func NewExecutorServiceServer ¶

func NewExecutorServiceServer(registry *modules.TypeRegistry) rpcv1connect.ExecutorServiceHandler

func NewHealthServer ¶

func NewHealthServer(logger *slog.Logger) healthv1connect.HealthHandler

Types ¶

type ContainerExecutionContext ¶

type ContainerExecutionContext struct {
	context.Context
	// contains filtered or unexported fields
}

func NewContainerExecutionContext ¶

func NewContainerExecutionContext(
	ctx context.Context,
	logger *slog.Logger,
	name,
	workingDir string,
	sender StreamSender[*remotev1.ExecutionServerMessage],
	remoteState *RemoteStateClient,
) *ContainerExecutionContext

func (ContainerExecutionContext) BinariesDir ¶

func (c ContainerExecutionContext) BinariesDir() string

func (ContainerExecutionContext) GetState ¶

func (c ContainerExecutionContext) GetState(ctx context.Context, key string) ([]byte, state.Metadata, error)

func (ContainerExecutionContext) Logger ¶

func (c ContainerExecutionContext) Logger() *slog.Logger

func (ContainerExecutionContext) Name ¶

func (c ContainerExecutionContext) Name() string

func (ContainerExecutionContext) OutDir ¶

func (c ContainerExecutionContext) OutDir() string

func (ContainerExecutionContext) SetState ¶

func (c ContainerExecutionContext) SetState(ctx context.Context, key string, value []byte) error

func (ContainerExecutionContext) StdErr ¶

func (c ContainerExecutionContext) StdErr() io.Writer

func (ContainerExecutionContext) StdOut ¶

func (c ContainerExecutionContext) StdOut() io.Writer

func (ContainerExecutionContext) WorkingDir ¶

func (c ContainerExecutionContext) WorkingDir() string

type ExecutorServiceServer ¶

type ExecutorServiceServer struct {
	// contains filtered or unexported fields
}

func (*ExecutorServiceServer) ExecuteStream ¶

func (e *ExecutorServiceServer) ExecuteStream(ctx context.Context, stream *connect.BidiStream[remotev1.ExecutionClientMessage, remotev1.ExecutionServerMessage]) (err error)

type GrpcExecutorHandler ¶

type GrpcExecutorHandler struct {
	Level slog.Level
	// contains filtered or unexported fields
}

func NewGrpcExecutorHandler ¶

func NewGrpcExecutorHandler(sender StreamSender[*remotev1.ExecutionServerMessage]) *GrpcExecutorHandler

func (GrpcExecutorHandler) Enabled ¶

func (g GrpcExecutorHandler) Enabled(_ context.Context, level slog.Level) bool

func (GrpcExecutorHandler) Handle ¶

func (g GrpcExecutorHandler) Handle(_ context.Context, record slog.Record) error

func (GrpcExecutorHandler) WithAttrs ¶

func (g GrpcExecutorHandler) WithAttrs(attrs []slog.Attr) slog.Handler

func (GrpcExecutorHandler) WithGroup ¶

func (g GrpcExecutorHandler) WithGroup(name string) slog.Handler

type PluginManagerServiceServer ¶

type PluginManagerServiceServer struct {
	// contains filtered or unexported fields
}

func (PluginManagerServiceServer) RegisterPluginModule ¶

func (p PluginManagerServiceServer) RegisterPluginModule(_ context.Context, request *connect.Request[remotev1.RegisterPluginModuleRequest]) (*connect.Response[remotev1.RegisterPluginModuleResponse], error)

type RemoteStateClient ¶

type RemoteStateClient struct {
	// contains filtered or unexported fields
}

func (*RemoteStateClient) GetState ¶

func (c *RemoteStateClient) GetState(ctx context.Context, key string) ([]byte, state.Metadata, error)

func (*RemoteStateClient) SetState ¶

func (c *RemoteStateClient) SetState(ctx context.Context, key string, value []byte) error

type RemoteTaskExecutor ¶

type RemoteTaskExecutor struct {
	// contains filtered or unexported fields
}

func (*RemoteTaskExecutor) Execute ¶

func (e *RemoteTaskExecutor) Execute(
	ctx context.Context,
	startTask *remotev1.StartTaskRequest,
) (resp chan *remotev1.TaskResult, errs chan error)

type RequestResponseClient ¶

type RequestResponseClient struct {
	// contains filtered or unexported fields
}

func NewRequestResponseClient ¶

func NewRequestResponseClient(logger *slog.Logger, sender StreamSender[*remotev1.ExecutionServerMessage]) *RequestResponseClient

func (*RequestResponseClient) DispatchMessages ¶

func (rrc *RequestResponseClient) DispatchMessages(receiver StreamReceiver[*remotev1.ExecutionClientMessage]) (errs chan error)

func (*RequestResponseClient) Send ¶

func (rrc *RequestResponseClient) Send(
	ctx context.Context,
	req *remotev1.ExecutionServerMessage,
) (resp *remotev1.ExecutionClientMessage, err error)

type StreamReceiver ¶

type StreamReceiver[T proto.Message] interface {
	Receive() (msg T, err error)
}

type StreamSender ¶

type StreamSender[T proto.Message] interface {
	Send(msg T) error
}

Source Files ¶

View all Source files

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