runner package - code.gitcaddy.com/server/v3/routers/api/actions/runner

Details

Learn more about best practices

Documentation ¶

Index ¶

func GetRunner(ctx context.Context) *actions_model.ActionRunner
func NewRunnerServiceHandler() (string, http.Handler)
type Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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)

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.

Source Files ¶

interceptor.go
runner.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL