service

Documentation

Overview

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

Index

• type StepRunnerService
  • func New(stepCache runner.Cache, env *runner.Environment) *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)
  • func (s *StepRunnerService) Status(ctx context.Context, request *proto.StatusRequest) (*proto.StatusResponse, error)

Types

type StepRunnerService

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

func New

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

func (*StepRunnerService) Close

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

func (*StepRunnerService) FollowLogs

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

func (*StepRunnerService) Run

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 (*StepRunnerService) Status

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