pipeline_api

Documentation

Index

• func CreateHandler(allocationCh chan runnermanager.RunnerAllocationRequest, ...)
• type ApiServer
  • func (s *ApiServer) AddRunnerToMap(u uuid.UUID, runner *runnermanager.Runner)
  • func (s *ApiServer) GetRunner(ctx context.Context, req *connect.Request[apiv2.GetRunnerRequest]) (*connect.Response[apiv2.GetRunnerResponse], error)
  • func (s *ApiServer) GetRunnerFromMap(u uuid.UUID) (*RunnerWrapper, bool)
  • func (s *ApiServer) ReleaseRunner(ctx context.Context, req *connect.Request[apiv2.ReleaseRunnerRequest]) (*connect.Response[apiv2.ReleaseRunnerResponse], error)
  • func (s *ApiServer) RunCommand(ctx context.Context, req *connect.Request[apiv2.RunCommandRequest]) (*connect.Response[apiv2.RunCommandResponse], error)
• type RunnerWrapper
  • func (r *RunnerWrapper) Release(releaseCh chan runnermanager.RunnerReleaseRequest)
  • func (r *RunnerWrapper) RunCommand(cmd string, args []string) (int64, string, string, error)

Functions

func CreateHandler

func CreateHandler(allocationCh chan runnermanager.RunnerAllocationRequest, releaseCh chan runnermanager.RunnerReleaseRequest, mux *http.ServeMux)

Types

type ApiServer

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

func (*ApiServer) AddRunnerToMap

func (s *ApiServer) AddRunnerToMap(u uuid.UUID, runner *runnermanager.Runner)

func (*ApiServer) GetRunner

func (s *ApiServer) GetRunner(
	ctx context.Context,
	req *connect.Request[apiv2.GetRunnerRequest],
) (*connect.Response[apiv2.GetRunnerResponse], error)

func (*ApiServer) GetRunnerFromMap

func (s *ApiServer) GetRunnerFromMap(u uuid.UUID) (*RunnerWrapper, bool)

func (*ApiServer) ReleaseRunner

func (s *ApiServer) ReleaseRunner(
	ctx context.Context,
	req *connect.Request[apiv2.ReleaseRunnerRequest],
) (*connect.Response[apiv2.ReleaseRunnerResponse], error)

func (*ApiServer) RunCommand

func (s *ApiServer) RunCommand(
	ctx context.Context,
	req *connect.Request[apiv2.RunCommandRequest],
) (*connect.Response[apiv2.RunCommandResponse], error)

type RunnerWrapper

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

func (*RunnerWrapper) Release

func (r *RunnerWrapper) Release(releaseCh chan runnermanager.RunnerReleaseRequest)

func (*RunnerWrapper) RunCommand

func (r *RunnerWrapper) RunCommand(cmd string, args []string) (int64, string, string, error)