service

package

v0.36.0 Latest Latest Go to latest Published: May 1, 2026 License: MIT Imports: 15 Imported by: 0

Details

Package service implements the gRPC API declared in ../../../proto/step.proto

This section is empty.

This section is empty.

func ErrorOnPanic() []grpc.ServerOption

ErrorOnPanic returns grpc.ServerOption values that wire up panic recovery interceptors.

func WithExecutor(executor func(delegate func())) func(service *StepRunnerService)

type PanicError struct {
	Method string
	Value  any
	Stack  []byte
}

PanicError represents a recovered panic with its stack trace.

func (e *PanicError) Error() string

func (e *PanicError) GRPCStatus() *status.Status

GRPCStatus returns a gRPC status so the error is transmitted as codes.Internal over the wire.

type StepRunnerService struct {
	proto.StepRunnerServer
	// contains filtered or unexported fields
}

StepRunnerService implements the gRPC StepRunner service.

func New(stepParser runner.StepParser, env *runner.Environment, options ...func(*StepRunnerService)) *StepRunnerService

func (s *StepRunnerService) Cancel(_ context.Context, request *proto.CancelRequest) (*proto.CancelResponse, error)

func (s *StepRunnerService) Close(_ context.Context, request *proto.CloseRequest) (*proto.CloseResponse, error)

func (s *StepRunnerService) FollowLogs(request *proto.FollowLogsRequest, writer proto.StepRunner_FollowLogsServer) error

func (s *StepRunnerService) Run(ctx context.Context, request *proto.RunRequest) (response *proto.RunResponse, err error)

Run parses, prepares, and initiates execution of a RunRequest.

func (s *StepRunnerService) Status(ctx context.Context, request *proto.StatusRequest) (*proto.StatusResponse, error)