[auto-commit] Generate codes

2024-02-28 04:25:44 +00:00 · 2023-06-12 08:18:48 +00:00 · 2023-06-06 00:25:59 +00:00
6 changed files with 611 additions and 294 deletions
--- a/go.mod
+++ b/go.mod
@@ -3,6 +3,6 @@ module code.gitea.io/actions-proto-go
 go 1.19

 require (
-	github.com/bufbuild/connect-go v1.3.1
-	google.golang.org/protobuf v1.28.1
+	connectrpc.com/connect v1.15.0
+	google.golang.org/protobuf v1.32.0
 )
--- a/go.sum
+++ b/go.sum
@@ -1,9 +1,7 @@
-github.com/bufbuild/connect-go v1.3.1 h1:doJP6Q8Ypg6haUT2IAZJPWHUN9rAUp+F9MfK7yhu1zs=
-github.com/bufbuild/connect-go v1.3.1/go.mod h1:9iNvh/NOsfhNBUH5CtvXeVUskQO1xsrEviH7ZArwZ3I=
-github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
-github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+connectrpc.com/connect v1.15.0 h1:lFdeCbZrVVDydAqwr4xGV2y+ULn+0Z73s5JBj2LikWo=
+connectrpc.com/connect v1.15.0/go.mod h1:bQmjpDY8xItMnttnurVgOkHUBMRT9cpsNi2O4AjKhmA=
 github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
-google.golang.org/protobuf v1.28.1 h1:d0NfwRgPtno5B1Wa6L2DAG+KivqkdutMf1UhdNx175w=
-google.golang.org/protobuf v1.28.1/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
+golang.org/x/net v0.21.0 h1:AQyQV4dYCvJ7vGmJyKki9+PBdyvhkSd8EIx/qb0AYv4=
+golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
+google.golang.org/protobuf v1.32.0 h1:pPC6BG5ex8PDFnkbrGU3EixyhKcQ2aDuBS36lqK/C7I=
+google.golang.org/protobuf v1.32.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
--- a/ping/v1/pingv1connect/services.connect.go
+++ b/ping/v1/pingv1connect/services.connect.go
@@ -6,9 +6,9 @@ package pingv1connect

 import (
 	v1 "code.gitea.io/actions-proto-go/ping/v1"
+	connect "connectrpc.com/connect"
 	context "context"
 	errors "errors"
-	connect_go "github.com/bufbuild/connect-go"
 	http "net/http"
 	strings "strings"
 )
@@ -18,16 +18,34 @@ import (
 // generated with a version of connect newer than the one compiled into your binary. You can fix the
 // problem by either regenerating this code with an older version of connect or updating the connect
 // version compiled into your binary.
-const _ = connect_go.IsAtLeastVersion0_1_0
+const _ = connect.IsAtLeastVersion1_13_0

 const (
 	// PingServiceName is the fully-qualified name of the PingService service.
 	PingServiceName = "ping.v1.PingService"
 )

+// These constants are the fully-qualified names of the RPCs defined in this package. They're
+// exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
+//
+// Note that these are different from the fully-qualified method names used by
+// google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to
+// reflection-formatted method names, remove the leading slash and convert the remaining slash to a
+// period.
+const (
+	// PingServicePingProcedure is the fully-qualified name of the PingService's Ping RPC.
+	PingServicePingProcedure = "/ping.v1.PingService/Ping"
+)
+
+// These variables are the protoreflect.Descriptor objects for the RPCs defined in this package.
+var (
+	pingServiceServiceDescriptor    = v1.File_ping_v1_services_proto.Services().ByName("PingService")
+	pingServicePingMethodDescriptor = pingServiceServiceDescriptor.Methods().ByName("Ping")
+)
+
 // PingServiceClient is a client for the ping.v1.PingService service.
 type PingServiceClient interface {
-	Ping(context.Context, *connect_go.Request[v1.PingRequest]) (*connect_go.Response[v1.PingResponse], error)
+	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
 }

 // NewPingServiceClient constructs a client for the ping.v1.PingService service. By default, it uses
@@ -37,30 +55,31 @@ type PingServiceClient interface {
 //
 // The URL supplied here should be the base URL for the Connect or gRPC server (for example,
 // http://api.acme.com or https://acme.com/grpc).
-func NewPingServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) PingServiceClient {
+func NewPingServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PingServiceClient {
 	baseURL = strings.TrimRight(baseURL, "/")
 	return &pingServiceClient{
-		ping: connect_go.NewClient[v1.PingRequest, v1.PingResponse](
+		ping: connect.NewClient[v1.PingRequest, v1.PingResponse](
 			httpClient,
-			baseURL+"/ping.v1.PingService/Ping",
-			opts...,
+			baseURL+PingServicePingProcedure,
+			connect.WithSchema(pingServicePingMethodDescriptor),
+			connect.WithClientOptions(opts...),
 		),
 	}
 }

 // pingServiceClient implements PingServiceClient.
 type pingServiceClient struct {
-	ping *connect_go.Client[v1.PingRequest, v1.PingResponse]
+	ping *connect.Client[v1.PingRequest, v1.PingResponse]
 }

 // Ping calls ping.v1.PingService.Ping.
-func (c *pingServiceClient) Ping(ctx context.Context, req *connect_go.Request[v1.PingRequest]) (*connect_go.Response[v1.PingResponse], error) {
+func (c *pingServiceClient) Ping(ctx context.Context, req *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) {
 	return c.ping.CallUnary(ctx, req)
 }

 // PingServiceHandler is an implementation of the ping.v1.PingService service.
 type PingServiceHandler interface {
-	Ping(context.Context, *connect_go.Request[v1.PingRequest]) (*connect_go.Response[v1.PingResponse], error)
+	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
 }

 // NewPingServiceHandler builds an HTTP handler from the service implementation. It returns the path
@@ -68,19 +87,26 @@ type PingServiceHandler interface {
 //
 // By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf
 // and JSON codecs. They also support gzip compression.
-func NewPingServiceHandler(svc PingServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler) {
-	mux := http.NewServeMux()
-	mux.Handle("/ping.v1.PingService/Ping", connect_go.NewUnaryHandler(
-		"/ping.v1.PingService/Ping",
+func NewPingServiceHandler(svc PingServiceHandler, opts ...connect.HandlerOption) (string, http.Handler) {
+	pingServicePingHandler := connect.NewUnaryHandler(
+		PingServicePingProcedure,
 		svc.Ping,
-		opts...,
-	))
-	return "/ping.v1.PingService/", mux
+		connect.WithSchema(pingServicePingMethodDescriptor),
+		connect.WithHandlerOptions(opts...),
+	)
+	return "/ping.v1.PingService/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		switch r.URL.Path {
+		case PingServicePingProcedure:
+			pingServicePingHandler.ServeHTTP(w, r)
+		default:
+			http.NotFound(w, r)
+		}
+	})
 }

 // UnimplementedPingServiceHandler returns CodeUnimplemented from all methods.
 type UnimplementedPingServiceHandler struct{}

-func (UnimplementedPingServiceHandler) Ping(context.Context, *connect_go.Request[v1.PingRequest]) (*connect_go.Response[v1.PingResponse], error) {
-	return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("ping.v1.PingService.Ping is not implemented"))
+func (UnimplementedPingServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ping.v1.PingService.Ping is not implemented"))
 }
--- a/runner/v1/messages.pb.go
+++ b/runner/v1/messages.pb.go
@@ -136,10 +136,14 @@ type RegisterRequest struct {
 	sizeCache     protoimpl.SizeCache
 	unknownFields protoimpl.UnknownFields

-	Name         string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
-	Token        string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
-	AgentLabels  []string `protobuf:"bytes,3,rep,name=agent_labels,json=agentLabels,proto3" json:"agent_labels,omitempty"`
+	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
+	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
+	// Deprecated: Do not use.
+	AgentLabels []string `protobuf:"bytes,3,rep,name=agent_labels,json=agentLabels,proto3" json:"agent_labels,omitempty"`
+	// Deprecated: Do not use.
 	CustomLabels []string `protobuf:"bytes,4,rep,name=custom_labels,json=customLabels,proto3" json:"custom_labels,omitempty"`
+	Version      string   `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
+	Labels       []string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"`
 }

 func (x *RegisterRequest) Reset() {
@@ -188,6 +192,7 @@ func (x *RegisterRequest) GetToken() string {
 	return ""
 }

+// Deprecated: Do not use.
 func (x *RegisterRequest) GetAgentLabels() []string {
 	if x != nil {
 		return x.AgentLabels
@@ -195,6 +200,7 @@ func (x *RegisterRequest) GetAgentLabels() []string {
 	return nil
 }

+// Deprecated: Do not use.
 func (x *RegisterRequest) GetCustomLabels() []string {
 	if x != nil {
 		return x.CustomLabels
@@ -202,6 +208,20 @@ func (x *RegisterRequest) GetCustomLabels() []string {
 	return nil
 }

+func (x *RegisterRequest) GetVersion() string {
+	if x != nil {
+		return x.Version
+	}
+	return ""
+}
+
+func (x *RegisterRequest) GetLabels() []string {
+	if x != nil {
+		return x.Labels
+	}
+	return nil
+}
+
 type RegisterResponse struct {
 	state         protoimpl.MessageState
 	sizeCache     protoimpl.SizeCache
@@ -249,16 +269,120 @@ func (x *RegisterResponse) GetRunner() *Runner {
 	return nil
 }

+type DeclareRequest struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Version string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
+	Labels  []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
+}
+
+func (x *DeclareRequest) Reset() {
+	*x = DeclareRequest{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_runner_v1_messages_proto_msgTypes[2]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *DeclareRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DeclareRequest) ProtoMessage() {}
+
+func (x *DeclareRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_runner_v1_messages_proto_msgTypes[2]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use DeclareRequest.ProtoReflect.Descriptor instead.
+func (*DeclareRequest) Descriptor() ([]byte, []int) {
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{2}
+}
+
+func (x *DeclareRequest) GetVersion() string {
+	if x != nil {
+		return x.Version
+	}
+	return ""
+}
+
+func (x *DeclareRequest) GetLabels() []string {
+	if x != nil {
+		return x.Labels
+	}
+	return nil
+}
+
+type DeclareResponse struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Runner *Runner `protobuf:"bytes,1,opt,name=runner,proto3" json:"runner,omitempty"`
+}
+
+func (x *DeclareResponse) Reset() {
+	*x = DeclareResponse{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_runner_v1_messages_proto_msgTypes[3]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *DeclareResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DeclareResponse) ProtoMessage() {}
+
+func (x *DeclareResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_runner_v1_messages_proto_msgTypes[3]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use DeclareResponse.ProtoReflect.Descriptor instead.
+func (*DeclareResponse) Descriptor() ([]byte, []int) {
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{3}
+}
+
+func (x *DeclareResponse) GetRunner() *Runner {
+	if x != nil {
+		return x.Runner
+	}
+	return nil
+}
+
 type FetchTaskRequest struct {
 	state         protoimpl.MessageState
 	sizeCache     protoimpl.SizeCache
 	unknownFields protoimpl.UnknownFields
+
+	TasksVersion int64 `protobuf:"varint,1,opt,name=tasks_version,json=tasksVersion,proto3" json:"tasks_version,omitempty"` // Runner use `tasks_version` to compare with Gitea and detemine whether new tasks may exist.
 }

 func (x *FetchTaskRequest) Reset() {
 	*x = FetchTaskRequest{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[2]
+		mi := &file_runner_v1_messages_proto_msgTypes[4]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -271,7 +395,7 @@ func (x *FetchTaskRequest) String() string {
 func (*FetchTaskRequest) ProtoMessage() {}

 func (x *FetchTaskRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[2]
+	mi := &file_runner_v1_messages_proto_msgTypes[4]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -284,7 +408,14 @@ func (x *FetchTaskRequest) ProtoReflect() protoreflect.Message {

 // Deprecated: Use FetchTaskRequest.ProtoReflect.Descriptor instead.
 func (*FetchTaskRequest) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{2}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{4}
+}
+
+func (x *FetchTaskRequest) GetTasksVersion() int64 {
+	if x != nil {
+		return x.TasksVersion
+	}
+	return 0
 }

 type FetchTaskResponse struct {
@@ -292,13 +423,14 @@ type FetchTaskResponse struct {
 	sizeCache     protoimpl.SizeCache
 	unknownFields protoimpl.UnknownFields

-	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
+	Task         *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
+	TasksVersion int64 `protobuf:"varint,2,opt,name=tasks_version,json=tasksVersion,proto3" json:"tasks_version,omitempty"` // Gitea informs the Runner of the latest version of tasks through `tasks_version`.
 }

 func (x *FetchTaskResponse) Reset() {
 	*x = FetchTaskResponse{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[3]
+		mi := &file_runner_v1_messages_proto_msgTypes[5]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -311,7 +443,7 @@ func (x *FetchTaskResponse) String() string {
 func (*FetchTaskResponse) ProtoMessage() {}

 func (x *FetchTaskResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[3]
+	mi := &file_runner_v1_messages_proto_msgTypes[5]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -324,7 +456,7 @@ func (x *FetchTaskResponse) ProtoReflect() protoreflect.Message {

 // Deprecated: Use FetchTaskResponse.ProtoReflect.Descriptor instead.
 func (*FetchTaskResponse) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{3}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{5}
 }

 func (x *FetchTaskResponse) GetTask() *Task {
@@ -334,6 +466,13 @@ func (x *FetchTaskResponse) GetTask() *Task {
 	return nil
 }

+func (x *FetchTaskResponse) GetTasksVersion() int64 {
+	if x != nil {
+		return x.TasksVersion
+	}
+	return 0
+}
+
 type UpdateTaskRequest struct {
 	state         protoimpl.MessageState
 	sizeCache     protoimpl.SizeCache
@@ -346,7 +485,7 @@ type UpdateTaskRequest struct {
 func (x *UpdateTaskRequest) Reset() {
 	*x = UpdateTaskRequest{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[4]
+		mi := &file_runner_v1_messages_proto_msgTypes[6]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -359,7 +498,7 @@ func (x *UpdateTaskRequest) String() string {
 func (*UpdateTaskRequest) ProtoMessage() {}

 func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[4]
+	mi := &file_runner_v1_messages_proto_msgTypes[6]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -372,7 +511,7 @@ func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message {

 // Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.
 func (*UpdateTaskRequest) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{4}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{6}
 }

 func (x *UpdateTaskRequest) GetState() *TaskState {
@@ -401,7 +540,7 @@ type UpdateTaskResponse struct {
 func (x *UpdateTaskResponse) Reset() {
 	*x = UpdateTaskResponse{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[5]
+		mi := &file_runner_v1_messages_proto_msgTypes[7]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -414,7 +553,7 @@ func (x *UpdateTaskResponse) String() string {
 func (*UpdateTaskResponse) ProtoMessage() {}

 func (x *UpdateTaskResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[5]
+	mi := &file_runner_v1_messages_proto_msgTypes[7]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -427,7 +566,7 @@ func (x *UpdateTaskResponse) ProtoReflect() protoreflect.Message {

 // Deprecated: Use UpdateTaskResponse.ProtoReflect.Descriptor instead.
 func (*UpdateTaskResponse) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{5}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{7}
 }

 func (x *UpdateTaskResponse) GetState() *TaskState {
@@ -458,7 +597,7 @@ type UpdateLogRequest struct {
 func (x *UpdateLogRequest) Reset() {
 	*x = UpdateLogRequest{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[6]
+		mi := &file_runner_v1_messages_proto_msgTypes[8]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -471,7 +610,7 @@ func (x *UpdateLogRequest) String() string {
 func (*UpdateLogRequest) ProtoMessage() {}

 func (x *UpdateLogRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[6]
+	mi := &file_runner_v1_messages_proto_msgTypes[8]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -484,7 +623,7 @@ func (x *UpdateLogRequest) ProtoReflect() protoreflect.Message {

 // Deprecated: Use UpdateLogRequest.ProtoReflect.Descriptor instead.
 func (*UpdateLogRequest) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{6}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{8}
 }

 func (x *UpdateLogRequest) GetTaskId() int64 {
@@ -526,7 +665,7 @@ type UpdateLogResponse struct {
 func (x *UpdateLogResponse) Reset() {
 	*x = UpdateLogResponse{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[7]
+		mi := &file_runner_v1_messages_proto_msgTypes[9]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -539,7 +678,7 @@ func (x *UpdateLogResponse) String() string {
 func (*UpdateLogResponse) ProtoMessage() {}

 func (x *UpdateLogResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[7]
+	mi := &file_runner_v1_messages_proto_msgTypes[9]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -552,7 +691,7 @@ func (x *UpdateLogResponse) ProtoReflect() protoreflect.Message {

 // Deprecated: Use UpdateLogResponse.ProtoReflect.Descriptor instead.
 func (*UpdateLogResponse) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{7}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{9}
 }

 func (x *UpdateLogResponse) GetAckIndex() int64 {
@@ -568,19 +707,23 @@ type Runner struct {
 	sizeCache     protoimpl.SizeCache
 	unknownFields protoimpl.UnknownFields

-	Id           int64        `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
-	Uuid         string       `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
-	Token        string       `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
-	Name         string       `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
-	Status       RunnerStatus `protobuf:"varint,5,opt,name=status,proto3,enum=runner.v1.RunnerStatus" json:"status,omitempty"`
-	AgentLabels  []string     `protobuf:"bytes,6,rep,name=agent_labels,json=agentLabels,proto3" json:"agent_labels,omitempty"`
-	CustomLabels []string     `protobuf:"bytes,7,rep,name=custom_labels,json=customLabels,proto3" json:"custom_labels,omitempty"`
+	Id     int64        `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
+	Uuid   string       `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
+	Token  string       `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
+	Name   string       `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
+	Status RunnerStatus `protobuf:"varint,5,opt,name=status,proto3,enum=runner.v1.RunnerStatus" json:"status,omitempty"`
+	// Deprecated: Do not use.
+	AgentLabels []string `protobuf:"bytes,6,rep,name=agent_labels,json=agentLabels,proto3" json:"agent_labels,omitempty"`
+	// Deprecated: Do not use.
+	CustomLabels []string `protobuf:"bytes,7,rep,name=custom_labels,json=customLabels,proto3" json:"custom_labels,omitempty"`
+	Version      string   `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
+	Labels       []string `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty"`
 }

 func (x *Runner) Reset() {
 	*x = Runner{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[8]
+		mi := &file_runner_v1_messages_proto_msgTypes[10]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -593,7 +736,7 @@ func (x *Runner) String() string {
 func (*Runner) ProtoMessage() {}

 func (x *Runner) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[8]
+	mi := &file_runner_v1_messages_proto_msgTypes[10]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -606,7 +749,7 @@ func (x *Runner) ProtoReflect() protoreflect.Message {

 // Deprecated: Use Runner.ProtoReflect.Descriptor instead.
 func (*Runner) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{8}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{10}
 }

 func (x *Runner) GetId() int64 {
@@ -644,6 +787,7 @@ func (x *Runner) GetStatus() RunnerStatus {
 	return RunnerStatus_RUNNER_STATUS_UNSPECIFIED
 }

+// Deprecated: Do not use.
 func (x *Runner) GetAgentLabels() []string {
 	if x != nil {
 		return x.AgentLabels
@@ -651,6 +795,7 @@ func (x *Runner) GetAgentLabels() []string {
 	return nil
 }

+// Deprecated: Do not use.
 func (x *Runner) GetCustomLabels() []string {
 	if x != nil {
 		return x.CustomLabels
@@ -658,6 +803,20 @@ func (x *Runner) GetCustomLabels() []string {
 	return nil
 }

+func (x *Runner) GetVersion() string {
+	if x != nil {
+		return x.Version
+	}
+	return ""
+}
+
+func (x *Runner) GetLabels() []string {
+	if x != nil {
+		return x.Labels
+	}
+	return nil
+}
+
 // Task represents a task.
 type Task struct {
 	state         protoimpl.MessageState
@@ -677,7 +836,7 @@ type Task struct {
 func (x *Task) Reset() {
 	*x = Task{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[9]
+		mi := &file_runner_v1_messages_proto_msgTypes[11]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -690,7 +849,7 @@ func (x *Task) String() string {
 func (*Task) ProtoMessage() {}

 func (x *Task) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[9]
+	mi := &file_runner_v1_messages_proto_msgTypes[11]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -703,7 +862,7 @@ func (x *Task) ProtoReflect() protoreflect.Message {

 // Deprecated: Use Task.ProtoReflect.Descriptor instead.
 func (*Task) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{9}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{11}
 }

 func (x *Task) GetId() int64 {
@@ -769,7 +928,7 @@ type TaskNeed struct {
 func (x *TaskNeed) Reset() {
 	*x = TaskNeed{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[10]
+		mi := &file_runner_v1_messages_proto_msgTypes[12]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -782,7 +941,7 @@ func (x *TaskNeed) String() string {
 func (*TaskNeed) ProtoMessage() {}

 func (x *TaskNeed) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[10]
+	mi := &file_runner_v1_messages_proto_msgTypes[12]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -795,7 +954,7 @@ func (x *TaskNeed) ProtoReflect() protoreflect.Message {

 // Deprecated: Use TaskNeed.ProtoReflect.Descriptor instead.
 func (*TaskNeed) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{10}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{12}
 }

 func (x *TaskNeed) GetOutputs() map[string]string {
@@ -828,7 +987,7 @@ type TaskState struct {
 func (x *TaskState) Reset() {
 	*x = TaskState{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[11]
+		mi := &file_runner_v1_messages_proto_msgTypes[13]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -841,7 +1000,7 @@ func (x *TaskState) String() string {
 func (*TaskState) ProtoMessage() {}

 func (x *TaskState) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[11]
+	mi := &file_runner_v1_messages_proto_msgTypes[13]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -854,7 +1013,7 @@ func (x *TaskState) ProtoReflect() protoreflect.Message {

 // Deprecated: Use TaskState.ProtoReflect.Descriptor instead.
 func (*TaskState) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{11}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{13}
 }

 func (x *TaskState) GetId() int64 {
@@ -909,7 +1068,7 @@ type StepState struct {
 func (x *StepState) Reset() {
 	*x = StepState{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[12]
+		mi := &file_runner_v1_messages_proto_msgTypes[14]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -922,7 +1081,7 @@ func (x *StepState) String() string {
 func (*StepState) ProtoMessage() {}

 func (x *StepState) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[12]
+	mi := &file_runner_v1_messages_proto_msgTypes[14]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -935,7 +1094,7 @@ func (x *StepState) ProtoReflect() protoreflect.Message {

 // Deprecated: Use StepState.ProtoReflect.Descriptor instead.
 func (*StepState) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{12}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{14}
 }

 func (x *StepState) GetId() int64 {
@@ -993,7 +1152,7 @@ type LogRow struct {
 func (x *LogRow) Reset() {
 	*x = LogRow{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_runner_v1_messages_proto_msgTypes[13]
+		mi := &file_runner_v1_messages_proto_msgTypes[15]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -1006,7 +1165,7 @@ func (x *LogRow) String() string {
 func (*LogRow) ProtoMessage() {}

 func (x *LogRow) ProtoReflect() protoreflect.Message {
-	mi := &file_runner_v1_messages_proto_msgTypes[13]
+	mi := &file_runner_v1_messages_proto_msgTypes[15]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1019,7 +1178,7 @@ func (x *LogRow) ProtoReflect() protoreflect.Message {

 // Deprecated: Use LogRow.ProtoReflect.Descriptor instead.
 func (*LogRow) Descriptor() ([]byte, []int) {
-	return file_runner_v1_messages_proto_rawDescGZIP(), []int{13}
+	return file_runner_v1_messages_proto_rawDescGZIP(), []int{15}
 }

 func (x *LogRow) GetTime() *timestamppb.Timestamp {
@@ -1045,67 +1204,87 @@ var file_runner_v1_messages_proto_rawDesc = []byte{
 	0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x73, 0x74, 0x72, 0x75, 0x63, 0x74, 0x2e, 0x70, 0x72,
 	0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
 	0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70,
-	0x72, 0x6f, 0x74, 0x6f, 0x22, 0x83, 0x01, 0x0a, 0x0f, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65,
+	0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbd, 0x01, 0x0a, 0x0f, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65,
 	0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
 	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05,
 	0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b,
-	0x65, 0x6e, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x6c, 0x61, 0x62, 0x65,
-	0x6c, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x4c,
-	0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x5f,
-	0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0c, 0x63, 0x75,
-	0x73, 0x74, 0x6f, 0x6d, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x22, 0x3d, 0x0a, 0x10, 0x52, 0x65,
-	0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29,
-	0x0a, 0x06, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11,
-	0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x75, 0x6e, 0x6e, 0x65,
-	0x72, 0x52, 0x06, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x22, 0x12, 0x0a, 0x10, 0x46, 0x65, 0x74,
-	0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x38, 0x0a,
-	0x11, 0x46, 0x65, 0x74, 0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
-	0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
-	0x32, 0x0f, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x73,
-	0x6b, 0x52, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x22, 0xc0, 0x01, 0x0a, 0x11, 0x55, 0x70, 0x64, 0x61,
-	0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2a, 0x0a,
-	0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x72,
-	0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x53, 0x74, 0x61,
-	0x74, 0x65, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x12, 0x43, 0x0a, 0x07, 0x6f, 0x75, 0x74,
-	0x70, 0x75, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x72, 0x75, 0x6e,
-	0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73,
-	0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73,
-	0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x1a, 0x3a,
-	0x0a, 0x0c, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10,
-	0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79,
-	0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
-	0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x63, 0x0a, 0x12, 0x55, 0x70,
-	0x64, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
-	0x12, 0x2a, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
-	0x14, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b,
-	0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x12, 0x21, 0x0a, 0x0c,
-	0x73, 0x65, 0x6e, 0x74, 0x5f, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03,
-	0x28, 0x09, 0x52, 0x0b, 0x73, 0x65, 0x6e, 0x74, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x22,
-	0x81, 0x01, 0x0a, 0x10, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4c, 0x6f, 0x67, 0x52, 0x65, 0x71,
-	0x75, 0x65, 0x73, 0x74, 0x12, 0x17, 0x0a, 0x07, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x69, 0x64, 0x18,
-	0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x12, 0x14, 0x0a,
-	0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x69, 0x6e,
-	0x64, 0x65, 0x78, 0x12, 0x25, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28,
-	0x0b, 0x32, 0x11, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x6f,
-	0x67, 0x52, 0x6f, 0x77, 0x52, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x12, 0x17, 0x0a, 0x07, 0x6e, 0x6f,
-	0x5f, 0x6d, 0x6f, 0x72, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x6e, 0x6f, 0x4d,
-	0x6f, 0x72, 0x65, 0x22, 0x30, 0x0a, 0x11, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4c, 0x6f, 0x67,
-	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x61, 0x63, 0x6b, 0x5f,
-	0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x61, 0x63, 0x6b,
-	0x49, 0x6e, 0x64, 0x65, 0x78, 0x22, 0xcf, 0x01, 0x0a, 0x06, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72,
-	0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, 0x64,
-	0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
-	0x75, 0x75, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20,
-	0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61,
-	0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x2f,
-	0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x17,
-	0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x75, 0x6e, 0x6e, 0x65,
-	0x72, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12,
-	0x21, 0x0a, 0x0c, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18,
-	0x06, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x4c, 0x61, 0x62, 0x65,
-	0x6c, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x5f, 0x6c, 0x61, 0x62,
-	0x65, 0x6c, 0x73, 0x18, 0x07, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0c, 0x63, 0x75, 0x73, 0x74, 0x6f,
-	0x6d, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x22, 0x9a, 0x04, 0x0a, 0x04, 0x54, 0x61, 0x73, 0x6b,
+	0x65, 0x6e, 0x12, 0x25, 0x0a, 0x0c, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x6c, 0x61, 0x62, 0x65,
+	0x6c, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x0b, 0x61, 0x67,
+	0x65, 0x6e, 0x74, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x27, 0x0a, 0x0d, 0x63, 0x75, 0x73,
+	0x74, 0x6f, 0x6d, 0x5f, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09,
+	0x42, 0x02, 0x18, 0x01, 0x52, 0x0c, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x4c, 0x61, 0x62, 0x65,
+	0x6c, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20,
+	0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x16, 0x0a, 0x06,
+	0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x06, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x6c, 0x61,
+	0x62, 0x65, 0x6c, 0x73, 0x22, 0x3d, 0x0a, 0x10, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x72, 0x75, 0x6e, 0x6e,
+	0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65,
+	0x72, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x52, 0x06, 0x72, 0x75, 0x6e,
+	0x6e, 0x65, 0x72, 0x22, 0x42, 0x0a, 0x0e, 0x44, 0x65, 0x63, 0x6c, 0x61, 0x72, 0x65, 0x52, 0x65,
+	0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
+	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12,
+	0x16, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52,
+	0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x22, 0x3c, 0x0a, 0x0f, 0x44, 0x65, 0x63, 0x6c, 0x61,
+	0x72, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x72, 0x75,
+	0x6e, 0x6e, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x72, 0x75, 0x6e,
+	0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x52, 0x06, 0x72,
+	0x75, 0x6e, 0x6e, 0x65, 0x72, 0x22, 0x37, 0x0a, 0x10, 0x46, 0x65, 0x74, 0x63, 0x68, 0x54, 0x61,
+	0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x23, 0x0a, 0x0d, 0x74, 0x61, 0x73,
+	0x6b, 0x73, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
+	0x52, 0x0c, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x5d,
+	0x0a, 0x11, 0x46, 0x65, 0x74, 0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f,
+	0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28,
+	0x0b, 0x32, 0x0f, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61,
+	0x73, 0x6b, 0x52, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x12, 0x23, 0x0a, 0x0d, 0x74, 0x61, 0x73, 0x6b,
+	0x73, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52,
+	0x0c, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0xc0, 0x01,
+	0x0a, 0x11, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75,
+	0x65, 0x73, 0x74, 0x12, 0x2a, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01,
+	0x28, 0x0b, 0x32, 0x14, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x54,
+	0x61, 0x73, 0x6b, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x12,
+	0x43, 0x0a, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b,
+	0x32, 0x29, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64,
+	0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4f,
+	0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x07, 0x6f, 0x75, 0x74,
+	0x70, 0x75, 0x74, 0x73, 0x1a, 0x3a, 0x0a, 0x0c, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x45,
+	0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28,
+	0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
+	0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01,
+	0x22, 0x63, 0x0a, 0x12, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65,
+	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2a, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18,
+	0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76,
+	0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 0x73, 0x74, 0x61,
+	0x74, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x65, 0x6e, 0x74, 0x5f, 0x6f, 0x75, 0x74, 0x70, 0x75,
+	0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x73, 0x65, 0x6e, 0x74, 0x4f, 0x75,
+	0x74, 0x70, 0x75, 0x74, 0x73, 0x22, 0x81, 0x01, 0x0a, 0x10, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65,
+	0x4c, 0x6f, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x17, 0x0a, 0x07, 0x74, 0x61,
+	0x73, 0x6b, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x74, 0x61, 0x73,
+	0x6b, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x02, 0x20, 0x01,
+	0x28, 0x03, 0x52, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x25, 0x0a, 0x04, 0x72, 0x6f, 0x77,
+	0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72,
+	0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x6f, 0x67, 0x52, 0x6f, 0x77, 0x52, 0x04, 0x72, 0x6f, 0x77, 0x73,
+	0x12, 0x17, 0x0a, 0x07, 0x6e, 0x6f, 0x5f, 0x6d, 0x6f, 0x72, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28,
+	0x08, 0x52, 0x06, 0x6e, 0x6f, 0x4d, 0x6f, 0x72, 0x65, 0x22, 0x30, 0x0a, 0x11, 0x55, 0x70, 0x64,
+	0x61, 0x74, 0x65, 0x4c, 0x6f, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1b,
+	0x0a, 0x09, 0x61, 0x63, 0x6b, 0x5f, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28,
+	0x03, 0x52, 0x08, 0x61, 0x63, 0x6b, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x22, 0x89, 0x02, 0x0a, 0x06,
+	0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
+	0x28, 0x03, 0x52, 0x02, 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x02,
+	0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f,
+	0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e,
+	0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
+	0x6e, 0x61, 0x6d, 0x65, 0x12, 0x2f, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x05,
+	0x20, 0x01, 0x28, 0x0e, 0x32, 0x17, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31,
+	0x2e, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73,
+	0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x25, 0x0a, 0x0c, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x6c,
+	0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x06, 0x20, 0x03, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52,
+	0x0b, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x27, 0x0a, 0x0d,
+	0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x5f, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x07, 0x20,
+	0x03, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x0c, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x4c,
+	0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
+	0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12,
+	0x16, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 0x09, 0x52,
+	0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x22, 0x9a, 0x04, 0x0a, 0x04, 0x54, 0x61, 0x73, 0x6b,
 	0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, 0x64,
 	0x12, 0x2e, 0x0a, 0x10, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x70, 0x61, 0x79,
 	0x6c, 0x6f, 0x61, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0f, 0x77, 0x6f,
@@ -1226,60 +1405,63 @@ func file_runner_v1_messages_proto_rawDescGZIP() []byte {
 }

 var file_runner_v1_messages_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
-var file_runner_v1_messages_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
+var file_runner_v1_messages_proto_msgTypes = make([]protoimpl.MessageInfo, 21)
 var file_runner_v1_messages_proto_goTypes = []interface{}{
 	(RunnerStatus)(0),             // 0: runner.v1.RunnerStatus
 	(Result)(0),                   // 1: runner.v1.Result
 	(*RegisterRequest)(nil),       // 2: runner.v1.RegisterRequest
 	(*RegisterResponse)(nil),      // 3: runner.v1.RegisterResponse
-	(*FetchTaskRequest)(nil),      // 4: runner.v1.FetchTaskRequest
-	(*FetchTaskResponse)(nil),     // 5: runner.v1.FetchTaskResponse
-	(*UpdateTaskRequest)(nil),     // 6: runner.v1.UpdateTaskRequest
-	(*UpdateTaskResponse)(nil),    // 7: runner.v1.UpdateTaskResponse
-	(*UpdateLogRequest)(nil),      // 8: runner.v1.UpdateLogRequest
-	(*UpdateLogResponse)(nil),     // 9: runner.v1.UpdateLogResponse
-	(*Runner)(nil),                // 10: runner.v1.Runner
-	(*Task)(nil),                  // 11: runner.v1.Task
-	(*TaskNeed)(nil),              // 12: runner.v1.TaskNeed
-	(*TaskState)(nil),             // 13: runner.v1.TaskState
-	(*StepState)(nil),             // 14: runner.v1.StepState
-	(*LogRow)(nil),                // 15: runner.v1.LogRow
-	nil,                           // 16: runner.v1.UpdateTaskRequest.OutputsEntry
-	nil,                           // 17: runner.v1.Task.SecretsEntry
-	nil,                           // 18: runner.v1.Task.NeedsEntry
-	nil,                           // 19: runner.v1.Task.VarsEntry
-	nil,                           // 20: runner.v1.TaskNeed.OutputsEntry
-	(*structpb.Struct)(nil),       // 21: google.protobuf.Struct
-	(*timestamppb.Timestamp)(nil), // 22: google.protobuf.Timestamp
+	(*DeclareRequest)(nil),        // 4: runner.v1.DeclareRequest
+	(*DeclareResponse)(nil),       // 5: runner.v1.DeclareResponse
+	(*FetchTaskRequest)(nil),      // 6: runner.v1.FetchTaskRequest
+	(*FetchTaskResponse)(nil),     // 7: runner.v1.FetchTaskResponse
+	(*UpdateTaskRequest)(nil),     // 8: runner.v1.UpdateTaskRequest
+	(*UpdateTaskResponse)(nil),    // 9: runner.v1.UpdateTaskResponse
+	(*UpdateLogRequest)(nil),      // 10: runner.v1.UpdateLogRequest
+	(*UpdateLogResponse)(nil),     // 11: runner.v1.UpdateLogResponse
+	(*Runner)(nil),                // 12: runner.v1.Runner
+	(*Task)(nil),                  // 13: runner.v1.Task
+	(*TaskNeed)(nil),              // 14: runner.v1.TaskNeed
+	(*TaskState)(nil),             // 15: runner.v1.TaskState
+	(*StepState)(nil),             // 16: runner.v1.StepState
+	(*LogRow)(nil),                // 17: runner.v1.LogRow
+	nil,                           // 18: runner.v1.UpdateTaskRequest.OutputsEntry
+	nil,                           // 19: runner.v1.Task.SecretsEntry
+	nil,                           // 20: runner.v1.Task.NeedsEntry
+	nil,                           // 21: runner.v1.Task.VarsEntry
+	nil,                           // 22: runner.v1.TaskNeed.OutputsEntry
+	(*structpb.Struct)(nil),       // 23: google.protobuf.Struct
+	(*timestamppb.Timestamp)(nil), // 24: google.protobuf.Timestamp
 }
 var file_runner_v1_messages_proto_depIdxs = []int32{
-	10, // 0: runner.v1.RegisterResponse.runner:type_name -> runner.v1.Runner
-	11, // 1: runner.v1.FetchTaskResponse.task:type_name -> runner.v1.Task
-	13, // 2: runner.v1.UpdateTaskRequest.state:type_name -> runner.v1.TaskState
-	16, // 3: runner.v1.UpdateTaskRequest.outputs:type_name -> runner.v1.UpdateTaskRequest.OutputsEntry
-	13, // 4: runner.v1.UpdateTaskResponse.state:type_name -> runner.v1.TaskState
-	15, // 5: runner.v1.UpdateLogRequest.rows:type_name -> runner.v1.LogRow
-	0,  // 6: runner.v1.Runner.status:type_name -> runner.v1.RunnerStatus
-	21, // 7: runner.v1.Task.context:type_name -> google.protobuf.Struct
-	17, // 8: runner.v1.Task.secrets:type_name -> runner.v1.Task.SecretsEntry
-	18, // 9: runner.v1.Task.needs:type_name -> runner.v1.Task.NeedsEntry
-	19, // 10: runner.v1.Task.vars:type_name -> runner.v1.Task.VarsEntry
-	20, // 11: runner.v1.TaskNeed.outputs:type_name -> runner.v1.TaskNeed.OutputsEntry
-	1,  // 12: runner.v1.TaskNeed.result:type_name -> runner.v1.Result
-	1,  // 13: runner.v1.TaskState.result:type_name -> runner.v1.Result
-	22, // 14: runner.v1.TaskState.started_at:type_name -> google.protobuf.Timestamp
-	22, // 15: runner.v1.TaskState.stopped_at:type_name -> google.protobuf.Timestamp
-	14, // 16: runner.v1.TaskState.steps:type_name -> runner.v1.StepState
-	1,  // 17: runner.v1.StepState.result:type_name -> runner.v1.Result
-	22, // 18: runner.v1.StepState.started_at:type_name -> google.protobuf.Timestamp
-	22, // 19: runner.v1.StepState.stopped_at:type_name -> google.protobuf.Timestamp
-	22, // 20: runner.v1.LogRow.time:type_name -> google.protobuf.Timestamp
-	12, // 21: runner.v1.Task.NeedsEntry.value:type_name -> runner.v1.TaskNeed
-	22, // [22:22] is the sub-list for method output_type
-	22, // [22:22] is the sub-list for method input_type
-	22, // [22:22] is the sub-list for extension type_name
-	22, // [22:22] is the sub-list for extension extendee
-	0,  // [0:22] is the sub-list for field type_name
+	12, // 0: runner.v1.RegisterResponse.runner:type_name -> runner.v1.Runner
+	12, // 1: runner.v1.DeclareResponse.runner:type_name -> runner.v1.Runner
+	13, // 2: runner.v1.FetchTaskResponse.task:type_name -> runner.v1.Task
+	15, // 3: runner.v1.UpdateTaskRequest.state:type_name -> runner.v1.TaskState
+	18, // 4: runner.v1.UpdateTaskRequest.outputs:type_name -> runner.v1.UpdateTaskRequest.OutputsEntry
+	15, // 5: runner.v1.UpdateTaskResponse.state:type_name -> runner.v1.TaskState
+	17, // 6: runner.v1.UpdateLogRequest.rows:type_name -> runner.v1.LogRow
+	0,  // 7: runner.v1.Runner.status:type_name -> runner.v1.RunnerStatus
+	23, // 8: runner.v1.Task.context:type_name -> google.protobuf.Struct
+	19, // 9: runner.v1.Task.secrets:type_name -> runner.v1.Task.SecretsEntry
+	20, // 10: runner.v1.Task.needs:type_name -> runner.v1.Task.NeedsEntry
+	21, // 11: runner.v1.Task.vars:type_name -> runner.v1.Task.VarsEntry
+	22, // 12: runner.v1.TaskNeed.outputs:type_name -> runner.v1.TaskNeed.OutputsEntry
+	1,  // 13: runner.v1.TaskNeed.result:type_name -> runner.v1.Result
+	1,  // 14: runner.v1.TaskState.result:type_name -> runner.v1.Result
+	24, // 15: runner.v1.TaskState.started_at:type_name -> google.protobuf.Timestamp
+	24, // 16: runner.v1.TaskState.stopped_at:type_name -> google.protobuf.Timestamp
+	16, // 17: runner.v1.TaskState.steps:type_name -> runner.v1.StepState
+	1,  // 18: runner.v1.StepState.result:type_name -> runner.v1.Result
+	24, // 19: runner.v1.StepState.started_at:type_name -> google.protobuf.Timestamp
+	24, // 20: runner.v1.StepState.stopped_at:type_name -> google.protobuf.Timestamp
+	24, // 21: runner.v1.LogRow.time:type_name -> google.protobuf.Timestamp
+	14, // 22: runner.v1.Task.NeedsEntry.value:type_name -> runner.v1.TaskNeed
+	23, // [23:23] is the sub-list for method output_type
+	23, // [23:23] is the sub-list for method input_type
+	23, // [23:23] is the sub-list for extension type_name
+	23, // [23:23] is the sub-list for extension extendee
+	0,  // [0:23] is the sub-list for field type_name
 }

 func init() { file_runner_v1_messages_proto_init() }
@@ -1313,7 +1495,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*FetchTaskRequest); i {
+			switch v := v.(*DeclareRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1325,7 +1507,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*FetchTaskResponse); i {
+			switch v := v.(*DeclareResponse); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1337,7 +1519,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*UpdateTaskRequest); i {
+			switch v := v.(*FetchTaskRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1349,7 +1531,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*UpdateTaskResponse); i {
+			switch v := v.(*FetchTaskResponse); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1361,7 +1543,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*UpdateLogRequest); i {
+			switch v := v.(*UpdateTaskRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1373,7 +1555,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*UpdateLogResponse); i {
+			switch v := v.(*UpdateTaskResponse); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1385,7 +1567,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*Runner); i {
+			switch v := v.(*UpdateLogRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1397,7 +1579,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*Task); i {
+			switch v := v.(*UpdateLogResponse); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1409,7 +1591,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TaskNeed); i {
+			switch v := v.(*Runner); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1421,7 +1603,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TaskState); i {
+			switch v := v.(*Task); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1433,7 +1615,7 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*StepState); i {
+			switch v := v.(*TaskNeed); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1445,6 +1627,30 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 		file_runner_v1_messages_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*TaskState); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_runner_v1_messages_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*StepState); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_runner_v1_messages_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
 			switch v := v.(*LogRow); i {
 			case 0:
 				return &v.state
@@ -1457,14 +1663,14 @@ func file_runner_v1_messages_proto_init() {
 			}
 		}
 	}
-	file_runner_v1_messages_proto_msgTypes[9].OneofWrappers = []interface{}{}
+	file_runner_v1_messages_proto_msgTypes[11].OneofWrappers = []interface{}{}
 	type x struct{}
 	out := protoimpl.TypeBuilder{
 		File: protoimpl.DescBuilder{
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: file_runner_v1_messages_proto_rawDesc,
 			NumEnums:      2,
-			NumMessages:   19,
+			NumMessages:   21,
 			NumExtensions: 0,
 			NumServices:   0,
 		},
--- a/runner/v1/runnerv1connect/services.connect.go
+++ b/runner/v1/runnerv1connect/services.connect.go
@@ -6,9 +6,9 @@ package runnerv1connect

 import (
 	v1 "code.gitea.io/actions-proto-go/runner/v1"
+	connect "connectrpc.com/connect"
 	context "context"
 	errors "errors"
-	connect_go "github.com/bufbuild/connect-go"
 	http "net/http"
 	strings "strings"
 )
@@ -18,23 +18,56 @@ import (
 // generated with a version of connect newer than the one compiled into your binary. You can fix the
 // problem by either regenerating this code with an older version of connect or updating the connect
 // version compiled into your binary.
-const _ = connect_go.IsAtLeastVersion0_1_0
+const _ = connect.IsAtLeastVersion1_13_0

 const (
 	// RunnerServiceName is the fully-qualified name of the RunnerService service.
 	RunnerServiceName = "runner.v1.RunnerService"
 )

+// These constants are the fully-qualified names of the RPCs defined in this package. They're
+// exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
+//
+// Note that these are different from the fully-qualified method names used by
+// google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to
+// reflection-formatted method names, remove the leading slash and convert the remaining slash to a
+// period.
+const (
+	// RunnerServiceRegisterProcedure is the fully-qualified name of the RunnerService's Register RPC.
+	RunnerServiceRegisterProcedure = "/runner.v1.RunnerService/Register"
+	// RunnerServiceDeclareProcedure is the fully-qualified name of the RunnerService's Declare RPC.
+	RunnerServiceDeclareProcedure = "/runner.v1.RunnerService/Declare"
+	// RunnerServiceFetchTaskProcedure is the fully-qualified name of the RunnerService's FetchTask RPC.
+	RunnerServiceFetchTaskProcedure = "/runner.v1.RunnerService/FetchTask"
+	// RunnerServiceUpdateTaskProcedure is the fully-qualified name of the RunnerService's UpdateTask
+	// RPC.
+	RunnerServiceUpdateTaskProcedure = "/runner.v1.RunnerService/UpdateTask"
+	// RunnerServiceUpdateLogProcedure is the fully-qualified name of the RunnerService's UpdateLog RPC.
+	RunnerServiceUpdateLogProcedure = "/runner.v1.RunnerService/UpdateLog"
+)
+
+// These variables are the protoreflect.Descriptor objects for the RPCs defined in this package.
+var (
+	runnerServiceServiceDescriptor          = v1.File_runner_v1_services_proto.Services().ByName("RunnerService")
+	runnerServiceRegisterMethodDescriptor   = runnerServiceServiceDescriptor.Methods().ByName("Register")
+	runnerServiceDeclareMethodDescriptor    = runnerServiceServiceDescriptor.Methods().ByName("Declare")
+	runnerServiceFetchTaskMethodDescriptor  = runnerServiceServiceDescriptor.Methods().ByName("FetchTask")
+	runnerServiceUpdateTaskMethodDescriptor = runnerServiceServiceDescriptor.Methods().ByName("UpdateTask")
+	runnerServiceUpdateLogMethodDescriptor  = runnerServiceServiceDescriptor.Methods().ByName("UpdateLog")
+)
+
 // RunnerServiceClient is a client for the runner.v1.RunnerService service.
 type RunnerServiceClient interface {
 	// Register register a new runner in server.
-	Register(context.Context, *connect_go.Request[v1.RegisterRequest]) (*connect_go.Response[v1.RegisterResponse], error)
+	Register(context.Context, *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error)
+	// Declare declare runner's version and labels to Gitea before starting fetching task.
+	Declare(context.Context, *connect.Request[v1.DeclareRequest]) (*connect.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)
+	FetchTask(context.Context, *connect.Request[v1.FetchTaskRequest]) (*connect.Response[v1.FetchTaskResponse], error)
 	// UpdateTask updates the task status.
-	UpdateTask(context.Context, *connect_go.Request[v1.UpdateTaskRequest]) (*connect_go.Response[v1.UpdateTaskResponse], error)
+	UpdateTask(context.Context, *connect.Request[v1.UpdateTaskRequest]) (*connect.Response[v1.UpdateTaskResponse], error)
 	// UpdateLog uploads log of the task.
-	UpdateLog(context.Context, *connect_go.Request[v1.UpdateLogRequest]) (*connect_go.Response[v1.UpdateLogResponse], error)
+	UpdateLog(context.Context, *connect.Request[v1.UpdateLogRequest]) (*connect.Response[v1.UpdateLogResponse], error)
 }

 // NewRunnerServiceClient constructs a client for the runner.v1.RunnerService service. By default,
@@ -44,70 +77,88 @@ type RunnerServiceClient interface {
 //
 // The URL supplied here should be the base URL for the Connect or gRPC server (for example,
 // http://api.acme.com or https://acme.com/grpc).
-func NewRunnerServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) RunnerServiceClient {
+func NewRunnerServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) RunnerServiceClient {
 	baseURL = strings.TrimRight(baseURL, "/")
 	return &runnerServiceClient{
-		register: connect_go.NewClient[v1.RegisterRequest, v1.RegisterResponse](
+		register: connect.NewClient[v1.RegisterRequest, v1.RegisterResponse](
 			httpClient,
-			baseURL+"/runner.v1.RunnerService/Register",
-			opts...,
+			baseURL+RunnerServiceRegisterProcedure,
+			connect.WithSchema(runnerServiceRegisterMethodDescriptor),
+			connect.WithClientOptions(opts...),
 		),
-		fetchTask: connect_go.NewClient[v1.FetchTaskRequest, v1.FetchTaskResponse](
+		declare: connect.NewClient[v1.DeclareRequest, v1.DeclareResponse](
 			httpClient,
-			baseURL+"/runner.v1.RunnerService/FetchTask",
-			opts...,
+			baseURL+RunnerServiceDeclareProcedure,
+			connect.WithSchema(runnerServiceDeclareMethodDescriptor),
+			connect.WithClientOptions(opts...),
 		),
-		updateTask: connect_go.NewClient[v1.UpdateTaskRequest, v1.UpdateTaskResponse](
+		fetchTask: connect.NewClient[v1.FetchTaskRequest, v1.FetchTaskResponse](
 			httpClient,
-			baseURL+"/runner.v1.RunnerService/UpdateTask",
-			opts...,
+			baseURL+RunnerServiceFetchTaskProcedure,
+			connect.WithSchema(runnerServiceFetchTaskMethodDescriptor),
+			connect.WithClientOptions(opts...),
 		),
-		updateLog: connect_go.NewClient[v1.UpdateLogRequest, v1.UpdateLogResponse](
+		updateTask: connect.NewClient[v1.UpdateTaskRequest, v1.UpdateTaskResponse](
 			httpClient,
-			baseURL+"/runner.v1.RunnerService/UpdateLog",
-			opts...,
+			baseURL+RunnerServiceUpdateTaskProcedure,
+			connect.WithSchema(runnerServiceUpdateTaskMethodDescriptor),
+			connect.WithClientOptions(opts...),
+		),
+		updateLog: connect.NewClient[v1.UpdateLogRequest, v1.UpdateLogResponse](
+			httpClient,
+			baseURL+RunnerServiceUpdateLogProcedure,
+			connect.WithSchema(runnerServiceUpdateLogMethodDescriptor),
+			connect.WithClientOptions(opts...),
 		),
 	}
 }

 // runnerServiceClient implements RunnerServiceClient.
 type runnerServiceClient struct {
-	register   *connect_go.Client[v1.RegisterRequest, v1.RegisterResponse]
-	fetchTask  *connect_go.Client[v1.FetchTaskRequest, v1.FetchTaskResponse]
-	updateTask *connect_go.Client[v1.UpdateTaskRequest, v1.UpdateTaskResponse]
-	updateLog  *connect_go.Client[v1.UpdateLogRequest, v1.UpdateLogResponse]
+	register   *connect.Client[v1.RegisterRequest, v1.RegisterResponse]
+	declare    *connect.Client[v1.DeclareRequest, v1.DeclareResponse]
+	fetchTask  *connect.Client[v1.FetchTaskRequest, v1.FetchTaskResponse]
+	updateTask *connect.Client[v1.UpdateTaskRequest, v1.UpdateTaskResponse]
+	updateLog  *connect.Client[v1.UpdateLogRequest, v1.UpdateLogResponse]
 }

 // Register calls runner.v1.RunnerService.Register.
-func (c *runnerServiceClient) Register(ctx context.Context, req *connect_go.Request[v1.RegisterRequest]) (*connect_go.Response[v1.RegisterResponse], error) {
+func (c *runnerServiceClient) Register(ctx context.Context, req *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error) {
 	return c.register.CallUnary(ctx, req)
 }

+// Declare calls runner.v1.RunnerService.Declare.
+func (c *runnerServiceClient) Declare(ctx context.Context, req *connect.Request[v1.DeclareRequest]) (*connect.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) {
+func (c *runnerServiceClient) FetchTask(ctx context.Context, req *connect.Request[v1.FetchTaskRequest]) (*connect.Response[v1.FetchTaskResponse], error) {
 	return c.fetchTask.CallUnary(ctx, req)
 }

 // UpdateTask calls runner.v1.RunnerService.UpdateTask.
-func (c *runnerServiceClient) UpdateTask(ctx context.Context, req *connect_go.Request[v1.UpdateTaskRequest]) (*connect_go.Response[v1.UpdateTaskResponse], error) {
+func (c *runnerServiceClient) UpdateTask(ctx context.Context, req *connect.Request[v1.UpdateTaskRequest]) (*connect.Response[v1.UpdateTaskResponse], error) {
 	return c.updateTask.CallUnary(ctx, req)
 }

 // UpdateLog calls runner.v1.RunnerService.UpdateLog.
-func (c *runnerServiceClient) UpdateLog(ctx context.Context, req *connect_go.Request[v1.UpdateLogRequest]) (*connect_go.Response[v1.UpdateLogResponse], error) {
+func (c *runnerServiceClient) UpdateLog(ctx context.Context, req *connect.Request[v1.UpdateLogRequest]) (*connect.Response[v1.UpdateLogResponse], error) {
 	return c.updateLog.CallUnary(ctx, req)
 }

 // RunnerServiceHandler is an implementation of the runner.v1.RunnerService service.
 type RunnerServiceHandler interface {
 	// Register register a new runner in server.
-	Register(context.Context, *connect_go.Request[v1.RegisterRequest]) (*connect_go.Response[v1.RegisterResponse], error)
+	Register(context.Context, *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error)
+	// Declare declare runner's version and labels to Gitea before starting fetching task.
+	Declare(context.Context, *connect.Request[v1.DeclareRequest]) (*connect.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)
+	FetchTask(context.Context, *connect.Request[v1.FetchTaskRequest]) (*connect.Response[v1.FetchTaskResponse], error)
 	// UpdateTask updates the task status.
-	UpdateTask(context.Context, *connect_go.Request[v1.UpdateTaskRequest]) (*connect_go.Response[v1.UpdateTaskResponse], error)
+	UpdateTask(context.Context, *connect.Request[v1.UpdateTaskRequest]) (*connect.Response[v1.UpdateTaskResponse], error)
 	// UpdateLog uploads log of the task.
-	UpdateLog(context.Context, *connect_go.Request[v1.UpdateLogRequest]) (*connect_go.Response[v1.UpdateLogResponse], error)
+	UpdateLog(context.Context, *connect.Request[v1.UpdateLogRequest]) (*connect.Response[v1.UpdateLogResponse], error)
 }

 // NewRunnerServiceHandler builds an HTTP handler from the service implementation. It returns the
@@ -115,46 +166,74 @@ type RunnerServiceHandler interface {
 //
 // By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf
 // and JSON codecs. They also support gzip compression.
-func NewRunnerServiceHandler(svc RunnerServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler) {
-	mux := http.NewServeMux()
-	mux.Handle("/runner.v1.RunnerService/Register", connect_go.NewUnaryHandler(
-		"/runner.v1.RunnerService/Register",
+func NewRunnerServiceHandler(svc RunnerServiceHandler, opts ...connect.HandlerOption) (string, http.Handler) {
+	runnerServiceRegisterHandler := connect.NewUnaryHandler(
+		RunnerServiceRegisterProcedure,
 		svc.Register,
-		opts...,
-	))
-	mux.Handle("/runner.v1.RunnerService/FetchTask", connect_go.NewUnaryHandler(
-		"/runner.v1.RunnerService/FetchTask",
+		connect.WithSchema(runnerServiceRegisterMethodDescriptor),
+		connect.WithHandlerOptions(opts...),
+	)
+	runnerServiceDeclareHandler := connect.NewUnaryHandler(
+		RunnerServiceDeclareProcedure,
+		svc.Declare,
+		connect.WithSchema(runnerServiceDeclareMethodDescriptor),
+		connect.WithHandlerOptions(opts...),
+	)
+	runnerServiceFetchTaskHandler := connect.NewUnaryHandler(
+		RunnerServiceFetchTaskProcedure,
 		svc.FetchTask,
-		opts...,
-	))
-	mux.Handle("/runner.v1.RunnerService/UpdateTask", connect_go.NewUnaryHandler(
-		"/runner.v1.RunnerService/UpdateTask",
+		connect.WithSchema(runnerServiceFetchTaskMethodDescriptor),
+		connect.WithHandlerOptions(opts...),
+	)
+	runnerServiceUpdateTaskHandler := connect.NewUnaryHandler(
+		RunnerServiceUpdateTaskProcedure,
 		svc.UpdateTask,
-		opts...,
-	))
-	mux.Handle("/runner.v1.RunnerService/UpdateLog", connect_go.NewUnaryHandler(
-		"/runner.v1.RunnerService/UpdateLog",
+		connect.WithSchema(runnerServiceUpdateTaskMethodDescriptor),
+		connect.WithHandlerOptions(opts...),
+	)
+	runnerServiceUpdateLogHandler := connect.NewUnaryHandler(
+		RunnerServiceUpdateLogProcedure,
 		svc.UpdateLog,
-		opts...,
-	))
-	return "/runner.v1.RunnerService/", mux
+		connect.WithSchema(runnerServiceUpdateLogMethodDescriptor),
+		connect.WithHandlerOptions(opts...),
+	)
+	return "/runner.v1.RunnerService/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		switch r.URL.Path {
+		case RunnerServiceRegisterProcedure:
+			runnerServiceRegisterHandler.ServeHTTP(w, r)
+		case RunnerServiceDeclareProcedure:
+			runnerServiceDeclareHandler.ServeHTTP(w, r)
+		case RunnerServiceFetchTaskProcedure:
+			runnerServiceFetchTaskHandler.ServeHTTP(w, r)
+		case RunnerServiceUpdateTaskProcedure:
+			runnerServiceUpdateTaskHandler.ServeHTTP(w, r)
+		case RunnerServiceUpdateLogProcedure:
+			runnerServiceUpdateLogHandler.ServeHTTP(w, r)
+		default:
+			http.NotFound(w, r)
+		}
+	})
 }

 // UnimplementedRunnerServiceHandler returns CodeUnimplemented from all methods.
 type UnimplementedRunnerServiceHandler struct{}

-func (UnimplementedRunnerServiceHandler) Register(context.Context, *connect_go.Request[v1.RegisterRequest]) (*connect_go.Response[v1.RegisterResponse], error) {
-	return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("runner.v1.RunnerService.Register is not implemented"))
+func (UnimplementedRunnerServiceHandler) Register(context.Context, *connect.Request[v1.RegisterRequest]) (*connect.Response[v1.RegisterResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("runner.v1.RunnerService.Register 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"))
+func (UnimplementedRunnerServiceHandler) Declare(context.Context, *connect.Request[v1.DeclareRequest]) (*connect.Response[v1.DeclareResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("runner.v1.RunnerService.Declare is not implemented"))
 }

-func (UnimplementedRunnerServiceHandler) UpdateTask(context.Context, *connect_go.Request[v1.UpdateTaskRequest]) (*connect_go.Response[v1.UpdateTaskResponse], error) {
-	return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("runner.v1.RunnerService.UpdateTask is not implemented"))
+func (UnimplementedRunnerServiceHandler) FetchTask(context.Context, *connect.Request[v1.FetchTaskRequest]) (*connect.Response[v1.FetchTaskResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("runner.v1.RunnerService.FetchTask is not implemented"))
 }

-func (UnimplementedRunnerServiceHandler) UpdateLog(context.Context, *connect_go.Request[v1.UpdateLogRequest]) (*connect_go.Response[v1.UpdateLogResponse], error) {
-	return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("runner.v1.RunnerService.UpdateLog is not implemented"))
+func (UnimplementedRunnerServiceHandler) UpdateTask(context.Context, *connect.Request[v1.UpdateTaskRequest]) (*connect.Response[v1.UpdateTaskResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("runner.v1.RunnerService.UpdateTask is not implemented"))
+}
+
+func (UnimplementedRunnerServiceHandler) UpdateLog(context.Context, *connect.Request[v1.UpdateLogRequest]) (*connect.Response[v1.UpdateLogResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("runner.v1.RunnerService.UpdateLog is not implemented"))
 }
--- a/runner/v1/services.pb.go
+++ b/runner/v1/services.pb.go
@@ -26,59 +26,67 @@ var file_runner_v1_services_proto_rawDesc = []byte{
 	0x69, 0x63, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x09, 0x72, 0x75, 0x6e, 0x6e,
 	0x65, 0x72, 0x2e, 0x76, 0x31, 0x1a, 0x18, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2f, 0x76, 0x31,
 	0x2f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32,
-	0xb7, 0x02, 0x0a, 0x0d, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
+	0xfb, 0x02, 0x0a, 0x0d, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
 	0x65, 0x12, 0x45, 0x0a, 0x08, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x12, 0x1a, 0x2e,
 	0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74,
 	0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x72, 0x75, 0x6e, 0x6e,
 	0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65,
-	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x48, 0x0a, 0x09, 0x46, 0x65, 0x74, 0x63,
-	0x68, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x1b, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76,
-	0x31, 0x2e, 0x46, 0x65, 0x74, 0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65,
-	0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x46,
-	0x65, 0x74, 0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
-	0x22, 0x00, 0x12, 0x4b, 0x0a, 0x0a, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b,
-	0x12, 0x1c, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64,
-	0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d,
-	0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74,
-	0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12,
-	0x48, 0x0a, 0x09, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4c, 0x6f, 0x67, 0x12, 0x1b, 0x2e, 0x72,
-	0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4c,
-	0x6f, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x72, 0x75, 0x6e, 0x6e,
-	0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4c, 0x6f, 0x67, 0x52,
-	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x96, 0x01, 0x0a, 0x0d, 0x63, 0x6f,
-	0x6d, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x42, 0x0d, 0x53, 0x65, 0x72,
-	0x76, 0x69, 0x63, 0x65, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x31, 0x63, 0x6f,
-	0x64, 0x65, 0x2e, 0x67, 0x69, 0x74, 0x65, 0x61, 0x2e, 0x69, 0x6f, 0x2f, 0x61, 0x63, 0x74, 0x69,
-	0x6f, 0x6e, 0x73, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2d, 0x67, 0x6f, 0x2f, 0x72, 0x75, 0x6e,
-	0x6e, 0x65, 0x72, 0x2f, 0x76, 0x31, 0x3b, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x76, 0x31, 0xa2,
-	0x02, 0x03, 0x52, 0x58, 0x58, 0xaa, 0x02, 0x09, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x56,
-	0x31, 0xca, 0x02, 0x09, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x5c, 0x56, 0x31, 0xe2, 0x02, 0x15,
-	0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74,
-	0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x3a, 0x3a,
-	0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x42, 0x0a, 0x07, 0x44, 0x65, 0x63, 0x6c,
+	0x61, 0x72, 0x65, 0x12, 0x19, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e,
+	0x44, 0x65, 0x63, 0x6c, 0x61, 0x72, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a,
+	0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 0x63, 0x6c, 0x61,
+	0x72, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x48, 0x0a, 0x09,
+	0x46, 0x65, 0x74, 0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x1b, 0x2e, 0x72, 0x75, 0x6e, 0x6e,
+	0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x46, 0x65, 0x74, 0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x52,
+	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e,
+	0x76, 0x31, 0x2e, 0x46, 0x65, 0x74, 0x63, 0x68, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70,
+	0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x4b, 0x0a, 0x0a, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65,
+	0x54, 0x61, 0x73, 0x6b, 0x12, 0x1c, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31,
+	0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65,
+	0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55,
+	0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
+	0x65, 0x22, 0x00, 0x12, 0x48, 0x0a, 0x09, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4c, 0x6f, 0x67,
+	0x12, 0x1b, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64,
+	0x61, 0x74, 0x65, 0x4c, 0x6f, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e,
+	0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65,
+	0x4c, 0x6f, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x96, 0x01,
+	0x0a, 0x0d, 0x63, 0x6f, 0x6d, 0x2e, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x42,
+	0x0d, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01,
+	0x5a, 0x31, 0x63, 0x6f, 0x64, 0x65, 0x2e, 0x67, 0x69, 0x74, 0x65, 0x61, 0x2e, 0x69, 0x6f, 0x2f,
+	0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2d, 0x67, 0x6f,
+	0x2f, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2f, 0x76, 0x31, 0x3b, 0x72, 0x75, 0x6e, 0x6e, 0x65,
+	0x72, 0x76, 0x31, 0xa2, 0x02, 0x03, 0x52, 0x58, 0x58, 0xaa, 0x02, 0x09, 0x52, 0x75, 0x6e, 0x6e,
+	0x65, 0x72, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x09, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x5c, 0x56,
+	0x31, 0xe2, 0x02, 0x15, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50,
+	0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x52, 0x75, 0x6e, 0x6e,
+	0x65, 0x72, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }

 var file_runner_v1_services_proto_goTypes = []interface{}{
 	(*RegisterRequest)(nil),    // 0: runner.v1.RegisterRequest
-	(*FetchTaskRequest)(nil),   // 1: runner.v1.FetchTaskRequest
-	(*UpdateTaskRequest)(nil),  // 2: runner.v1.UpdateTaskRequest
-	(*UpdateLogRequest)(nil),   // 3: runner.v1.UpdateLogRequest
-	(*RegisterResponse)(nil),   // 4: runner.v1.RegisterResponse
-	(*FetchTaskResponse)(nil),  // 5: runner.v1.FetchTaskResponse
-	(*UpdateTaskResponse)(nil), // 6: runner.v1.UpdateTaskResponse
-	(*UpdateLogResponse)(nil),  // 7: runner.v1.UpdateLogResponse
+	(*DeclareRequest)(nil),     // 1: runner.v1.DeclareRequest
+	(*FetchTaskRequest)(nil),   // 2: runner.v1.FetchTaskRequest
+	(*UpdateTaskRequest)(nil),  // 3: runner.v1.UpdateTaskRequest
+	(*UpdateLogRequest)(nil),   // 4: runner.v1.UpdateLogRequest
+	(*RegisterResponse)(nil),   // 5: runner.v1.RegisterResponse
+	(*DeclareResponse)(nil),    // 6: runner.v1.DeclareResponse
+	(*FetchTaskResponse)(nil),  // 7: runner.v1.FetchTaskResponse
+	(*UpdateTaskResponse)(nil), // 8: runner.v1.UpdateTaskResponse
+	(*UpdateLogResponse)(nil),  // 9: runner.v1.UpdateLogResponse
 }
 var file_runner_v1_services_proto_depIdxs = []int32{
 	0, // 0: runner.v1.RunnerService.Register:input_type -> runner.v1.RegisterRequest
-	1, // 1: runner.v1.RunnerService.FetchTask:input_type -> runner.v1.FetchTaskRequest
-	2, // 2: runner.v1.RunnerService.UpdateTask:input_type -> runner.v1.UpdateTaskRequest
-	3, // 3: runner.v1.RunnerService.UpdateLog:input_type -> runner.v1.UpdateLogRequest
-	4, // 4: runner.v1.RunnerService.Register:output_type -> runner.v1.RegisterResponse
-	5, // 5: runner.v1.RunnerService.FetchTask:output_type -> runner.v1.FetchTaskResponse
-	6, // 6: runner.v1.RunnerService.UpdateTask:output_type -> runner.v1.UpdateTaskResponse
-	7, // 7: runner.v1.RunnerService.UpdateLog:output_type -> runner.v1.UpdateLogResponse
-	4, // [4:8] is the sub-list for method output_type
-	0, // [0:4] is the sub-list for method input_type
+	1, // 1: runner.v1.RunnerService.Declare:input_type -> runner.v1.DeclareRequest
+	2, // 2: runner.v1.RunnerService.FetchTask:input_type -> runner.v1.FetchTaskRequest
+	3, // 3: runner.v1.RunnerService.UpdateTask:input_type -> runner.v1.UpdateTaskRequest
+	4, // 4: runner.v1.RunnerService.UpdateLog:input_type -> runner.v1.UpdateLogRequest
+	5, // 5: runner.v1.RunnerService.Register:output_type -> runner.v1.RegisterResponse
+	6, // 6: runner.v1.RunnerService.Declare:output_type -> runner.v1.DeclareResponse
+	7, // 7: runner.v1.RunnerService.FetchTask:output_type -> runner.v1.FetchTaskResponse
+	8, // 8: runner.v1.RunnerService.UpdateTask:output_type -> runner.v1.UpdateTaskResponse
+	9, // 9: runner.v1.RunnerService.UpdateLog:output_type -> runner.v1.UpdateLogResponse
+	5, // [5:10] is the sub-list for method output_type
+	0, // [0:5] is the sub-list for method input_type
 	0, // [0:0] is the sub-list for extension type_name
 	0, // [0:0] is the sub-list for extension extendee
 	0, // [0:0] is the sub-list for field type_name
Author	SHA1	Message	Date
GiteaBot	367be5bb82	[auto-commit] Generate codes	2024-02-28 04:25:44 +00:00
GiteaBot	f2cdb357ee	[auto-commit] Generate codes	2023-06-12 08:18:48 +00:00
GiteaBot	f3d8a4e6d6	[auto-commit] Generate codes	2023-06-06 00:25:59 +00:00