runner

Documentation

Index

• func GetRunner(ctx context.Context) *actions_model.ActionRunner
• func NewRunnerServiceHandler() (string, http.Handler)
• type Service
  • func (s *Service) Declare(ctx context.Context, req *connect.Request[runnerv1.DeclareRequest]) (*connect.Response[runnerv1.DeclareResponse], error)
  • func (s *Service) FetchTask(ctx context.Context, req *connect.Request[runnerv1.FetchTaskRequest]) (*connect.Response[runnerv1.FetchTaskResponse], error)
  • func (s *Service) Register(ctx context.Context, req *connect.Request[runnerv1.RegisterRequest]) (*connect.Response[runnerv1.RegisterResponse], error)
  • func (s *Service) UpdateLog(ctx context.Context, req *connect.Request[runnerv1.UpdateLogRequest]) (*connect.Response[runnerv1.UpdateLogResponse], error)
  • func (s *Service) UpdateTask(ctx context.Context, req *connect.Request[runnerv1.UpdateTaskRequest]) (*connect.Response[runnerv1.UpdateTaskResponse], error)

Functions

func GetRunner

func GetRunner(ctx context.Context) *actions_model.ActionRunner

func NewRunnerServiceHandler

func NewRunnerServiceHandler() (string, http.Handler)

Types

type Service

type Service struct{}

func (*Service) Declare

func (s *Service) Declare(
	ctx context.Context,
	req *connect.Request[runnerv1.DeclareRequest],
) (*connect.Response[runnerv1.DeclareResponse], error)

func (*Service) FetchTask

func (s *Service) FetchTask(
	ctx context.Context,
	req *connect.Request[runnerv1.FetchTaskRequest],
) (*connect.Response[runnerv1.FetchTaskResponse], error)

FetchTask assigns a task to the runner

func (*Service) Register

func (s *Service) Register(
	ctx context.Context,
	req *connect.Request[runnerv1.RegisterRequest],
) (*connect.Response[runnerv1.RegisterResponse], error)

Register for new runner.

func (*Service) UpdateLog

func (s *Service) UpdateLog(
	ctx context.Context,
	req *connect.Request[runnerv1.UpdateLogRequest],
) (*connect.Response[runnerv1.UpdateLogResponse], error)

UpdateLog uploads log of the task.

func (*Service) UpdateTask

func (s *Service) UpdateTask(
	ctx context.Context,
	req *connect.Request[runnerv1.UpdateTaskRequest],
) (*connect.Response[runnerv1.UpdateTaskResponse], error)

UpdateTask updates the task status.