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

Compare commits

base: gitcaddy:v0.2.1
Branches Tags
gitcaddy:main
gitcaddy:v0.5.9 gitcaddy:v0.5.8 gitcaddy:v0.5.7 gitcaddy:v0.5.6 gitcaddy:v0.5.5 gitcaddy:v0.5.4 gitcaddy:v0.5.3 gitcaddy:v0.5.2 gitcaddy:v0.5.1 gitcaddy:v0.5.0 gitcaddy:v0.4.1 gitcaddy:v0.4.0 gitcaddy:v0.3.1 gitcaddy:v0.3.0 gitcaddy:v0.2.1 gitcaddy:v0.2.0 gitcaddy:v0.1.0
...
compare: gitcaddy:v0.3.1
Branches Tags
gitcaddy:main
gitcaddy:v0.5.9 gitcaddy:v0.5.8 gitcaddy:v0.5.7 gitcaddy:v0.5.6 gitcaddy:v0.5.5 gitcaddy:v0.5.4 gitcaddy:v0.5.3 gitcaddy:v0.5.2 gitcaddy:v0.5.1 gitcaddy:v0.5.0 gitcaddy:v0.4.1 gitcaddy:v0.4.0 gitcaddy:v0.3.1 gitcaddy:v0.3.0 gitcaddy:v0.2.1 gitcaddy:v0.2.0 gitcaddy:v0.1.0

2 Commits
v0.2.1 ... v0.3.1

Author SHA1 Message Date
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
3 changed files with 445 additions and 207 deletions
Expand all files Collapse all files

536
runner/v1/messages.pb.go
View File

@@ -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,
},

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"))
}

92
runner/v1/services.pb.go
View File

@@ -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