pipeline

Documentation

Index

• func NewRunnerClient(cc grpc.ClientConnInterface) *pipelineRunnerServiceClient
• type RunnerServer
  • func NewRunnerServer(impl core.PipelineRunnerService) *RunnerServer
  • func (p *RunnerServer) ExecuteRun(ctx context.Context, rr *pb.RunRequest) (*pb.RunResponse, error)

Functions

func NewRunnerClient

func NewRunnerClient(cc grpc.ClientConnInterface) *pipelineRunnerServiceClient

Types

type RunnerServer

type RunnerServer struct {
	pb.UnimplementedPipelineRunnerServiceServer
	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewRunnerServer

func NewRunnerServer(impl core.PipelineRunnerService) *RunnerServer

func (*RunnerServer) ExecuteRun

func (p *RunnerServer) ExecuteRun(ctx context.Context, rr *pb.RunRequest) (*pb.RunResponse, error)