service

package

v0.8.0 Latest Latest Go to latest Published: Apr 1, 2025 License: MIT Imports: 9 Imported by: 0

Details

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

This section is empty.

This section is empty.

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

func WithJobRunExitWaitTime(waitTime time.Duration) func(service *StepRunnerService)

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

func New(stepCache runner.Cache, env *runner.Environment, options ...func(*StepRunnerService)) *StepRunnerService

func (s *StepRunnerService) Close(ctx 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)