GitCaddy/GitCaddy Protocol
2
0
Fork 0
Code Issues Releases 7

[auto-commit] Generate codes

Browse Source
This commit is contained in:
GiteaBot
2023-06-06 00:25:59 +00:00
parent 624d2d8beb
commit f3d8a4e6d6
3 changed files with 523 additions and 306 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
runner/v1/runnerv1connect/services.connect.go
View File

@@ -29,6 +29,8 @@ const (
type RunnerServiceClient interface {
// Register register a new runner in server.
Register(context.Context, *connect_go.Request[v1.RegisterRequest]) (*connect_go.Response[v1.RegisterResponse], error)
// Declare declare runner's version and labels to Gitea before starting fetching task.
Declare(context.Context, *connect_go.Request[v1.DeclareRequest]) (*connect_go.Response[v1.DeclareResponse], error)
// FetchTask requests the next available task for execution.
FetchTask(context.Context, *connect_go.Request[v1.FetchTaskRequest]) (*connect_go.Response[v1.FetchTaskResponse], error)
// UpdateTask updates the task status.
@@ -52,6 +54,11 @@ func NewRunnerServiceClient(httpClient connect_go.HTTPClient, baseURL string, op
baseURL+"/runner.v1.RunnerService/Register",
opts...,
),
declare: connect_go.NewClient[v1.DeclareRequest, v1.DeclareResponse](
httpClient,
baseURL+"/runner.v1.RunnerService/Declare",
opts...,
),
fetchTask: connect_go.NewClient[v1.FetchTaskRequest, v1.FetchTaskResponse](
httpClient,
baseURL+"/runner.v1.RunnerService/FetchTask",
@@ -73,6 +80,7 @@ func NewRunnerServiceClient(httpClient connect_go.HTTPClient, baseURL string, op
// runnerServiceClient implements RunnerServiceClient.
type runnerServiceClient struct {
register *connect_go.Client[v1.RegisterRequest, v1.RegisterResponse]
declare *connect_go.Client[v1.DeclareRequest, v1.DeclareResponse]
fetchTask *connect_go.Client[v1.FetchTaskRequest, v1.FetchTaskResponse]
updateTask *connect_go.Client[v1.UpdateTaskRequest, v1.UpdateTaskResponse]
updateLog *connect_go.Client[v1.UpdateLogRequest, v1.UpdateLogResponse]
@@ -83,6 +91,11 @@ func (c *runnerServiceClient) Register(ctx context.Context, req *connect_go.Requ
return c.register.CallUnary(ctx, req)
}
// Declare calls runner.v1.RunnerService.Declare.
func (c *runnerServiceClient) Declare(ctx context.Context, req *connect_go.Request[v1.DeclareRequest]) (*connect_go.Response[v1.DeclareResponse], error) {
return c.declare.CallUnary(ctx, req)
}
// FetchTask calls runner.v1.RunnerService.FetchTask.
func (c *runnerServiceClient) FetchTask(ctx context.Context, req *connect_go.Request[v1.FetchTaskRequest]) (*connect_go.Response[v1.FetchTaskResponse], error) {
return c.fetchTask.CallUnary(ctx, req)
@@ -102,6 +115,8 @@ func (c *runnerServiceClient) UpdateLog(ctx context.Context, req *connect_go.Req
type RunnerServiceHandler interface {
// Register register a new runner in server.
Register(context.Context, *connect_go.Request[v1.RegisterRequest]) (*connect_go.Response[v1.RegisterResponse], error)
// Declare declare runner's version and labels to Gitea before starting fetching task.
Declare(context.Context, *connect_go.Request[v1.DeclareRequest]) (*connect_go.Response[v1.DeclareResponse], error)
// FetchTask requests the next available task for execution.
FetchTask(context.Context, *connect_go.Request[v1.FetchTaskRequest]) (*connect_go.Response[v1.FetchTaskResponse], error)
// UpdateTask updates the task status.
@@ -122,6 +137,11 @@ func NewRunnerServiceHandler(svc RunnerServiceHandler, opts ...connect_go.Handle
svc.Register,
opts...,
))
mux.Handle("/runner.v1.RunnerService/Declare", connect_go.NewUnaryHandler(
"/runner.v1.RunnerService/Declare",
svc.Declare,
opts...,
))
mux.Handle("/runner.v1.RunnerService/FetchTask", connect_go.NewUnaryHandler(
"/runner.v1.RunnerService/FetchTask",
svc.FetchTask,
@@ -147,6 +167,10 @@ func (UnimplementedRunnerServiceHandler) Register(context.Context, *connect_go.R
return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("runner.v1.RunnerService.Register is not implemented"))
}
func (UnimplementedRunnerServiceHandler) Declare(context.Context, *connect_go.Request[v1.DeclareRequest]) (*connect_go.Response[v1.DeclareResponse], error) {
return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("runner.v1.RunnerService.Declare is not implemented"))
}
func (UnimplementedRunnerServiceHandler) FetchTask(context.Context, *connect_go.Request[v1.FetchTaskRequest]) (*connect_go.Response[v1.FetchTaskResponse], error) {
return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("runner.v1.RunnerService.FetchTask is not implemented"))
}