From 5bb47903fed8dcf45d1221a274c32c2bd954bdc6 Mon Sep 17 00:00:00 2001 From: Tetsuya KIKUCHI <97105818+t-kikuc@users.noreply.github.com> Date: Wed, 8 Jan 2025 16:16:51 +0900 Subject: [PATCH] Add MetadataStore methods to PipedService (#5469) Signed-off-by: t-kikuc --- pkg/plugin/pipedservice/service.pb.go | 1023 +++++++++++- .../pipedservice/service.pb.validate.go | 1395 +++++++++++++++++ pkg/plugin/pipedservice/service.proto | 70 + pkg/plugin/pipedservice/service_grpc.pb.go | 228 +++ 4 files changed, 2671 insertions(+), 45 deletions(-) diff --git a/pkg/plugin/pipedservice/service.pb.go b/pkg/plugin/pipedservice/service.pb.go index 48dda4dcae..9bbc98eb40 100644 --- a/pkg/plugin/pipedservice/service.pb.go +++ b/pkg/plugin/pipedservice/service.pb.go @@ -484,6 +484,638 @@ func (*ReportStageLogsFromLastCheckpointResponse) Descriptor() ([]byte, []int) { return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{7} } +type GetStageMetadataRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` + StageId string `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"` + Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *GetStageMetadataRequest) Reset() { + *x = GetStageMetadataRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetStageMetadataRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetStageMetadataRequest) ProtoMessage() {} + +func (x *GetStageMetadataRequest) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[8] + 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 GetStageMetadataRequest.ProtoReflect.Descriptor instead. +func (*GetStageMetadataRequest) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{8} +} + +func (x *GetStageMetadataRequest) GetDeploymentId() string { + if x != nil { + return x.DeploymentId + } + return "" +} + +func (x *GetStageMetadataRequest) GetStageId() string { + if x != nil { + return x.StageId + } + return "" +} + +func (x *GetStageMetadataRequest) GetKey() string { + if x != nil { + return x.Key + } + return "" +} + +type GetStageMetadataResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` + Found bool `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"` +} + +func (x *GetStageMetadataResponse) Reset() { + *x = GetStageMetadataResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetStageMetadataResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetStageMetadataResponse) ProtoMessage() {} + +func (x *GetStageMetadataResponse) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[9] + 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 GetStageMetadataResponse.ProtoReflect.Descriptor instead. +func (*GetStageMetadataResponse) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{9} +} + +func (x *GetStageMetadataResponse) GetValue() string { + if x != nil { + return x.Value + } + return "" +} + +func (x *GetStageMetadataResponse) GetFound() bool { + if x != nil { + return x.Found + } + return false +} + +type PutStageMetadataRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` + StageId string `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"` + Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` + Value string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` +} + +func (x *PutStageMetadataRequest) Reset() { + *x = PutStageMetadataRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutStageMetadataRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutStageMetadataRequest) ProtoMessage() {} + +func (x *PutStageMetadataRequest) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[10] + 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 PutStageMetadataRequest.ProtoReflect.Descriptor instead. +func (*PutStageMetadataRequest) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{10} +} + +func (x *PutStageMetadataRequest) GetDeploymentId() string { + if x != nil { + return x.DeploymentId + } + return "" +} + +func (x *PutStageMetadataRequest) GetStageId() string { + if x != nil { + return x.StageId + } + return "" +} + +func (x *PutStageMetadataRequest) GetKey() string { + if x != nil { + return x.Key + } + return "" +} + +func (x *PutStageMetadataRequest) GetValue() string { + if x != nil { + return x.Value + } + return "" +} + +type PutStageMetadataResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *PutStageMetadataResponse) Reset() { + *x = PutStageMetadataResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutStageMetadataResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutStageMetadataResponse) ProtoMessage() {} + +func (x *PutStageMetadataResponse) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[11] + 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 PutStageMetadataResponse.ProtoReflect.Descriptor instead. +func (*PutStageMetadataResponse) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{11} +} + +type PutStageMetadataMultiRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` + StageId string `protobuf:"bytes,2,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"` + Metadata map[string]string `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` +} + +func (x *PutStageMetadataMultiRequest) Reset() { + *x = PutStageMetadataMultiRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutStageMetadataMultiRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutStageMetadataMultiRequest) ProtoMessage() {} + +func (x *PutStageMetadataMultiRequest) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[12] + 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 PutStageMetadataMultiRequest.ProtoReflect.Descriptor instead. +func (*PutStageMetadataMultiRequest) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{12} +} + +func (x *PutStageMetadataMultiRequest) GetDeploymentId() string { + if x != nil { + return x.DeploymentId + } + return "" +} + +func (x *PutStageMetadataMultiRequest) GetStageId() string { + if x != nil { + return x.StageId + } + return "" +} + +func (x *PutStageMetadataMultiRequest) GetMetadata() map[string]string { + if x != nil { + return x.Metadata + } + return nil +} + +type PutStageMetadataMultiResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *PutStageMetadataMultiResponse) Reset() { + *x = PutStageMetadataMultiResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[13] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutStageMetadataMultiResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutStageMetadataMultiResponse) ProtoMessage() {} + +func (x *PutStageMetadataMultiResponse) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[13] + 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 PutStageMetadataMultiResponse.ProtoReflect.Descriptor instead. +func (*PutStageMetadataMultiResponse) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{13} +} + +type GetDeploymentMetadataRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` + Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *GetDeploymentMetadataRequest) Reset() { + *x = GetDeploymentMetadataRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[14] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetDeploymentMetadataRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetDeploymentMetadataRequest) ProtoMessage() {} + +func (x *GetDeploymentMetadataRequest) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[14] + 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 GetDeploymentMetadataRequest.ProtoReflect.Descriptor instead. +func (*GetDeploymentMetadataRequest) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{14} +} + +func (x *GetDeploymentMetadataRequest) GetDeploymentId() string { + if x != nil { + return x.DeploymentId + } + return "" +} + +func (x *GetDeploymentMetadataRequest) GetKey() string { + if x != nil { + return x.Key + } + return "" +} + +type GetDeploymentMetadataResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` + Found bool `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"` +} + +func (x *GetDeploymentMetadataResponse) Reset() { + *x = GetDeploymentMetadataResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[15] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetDeploymentMetadataResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetDeploymentMetadataResponse) ProtoMessage() {} + +func (x *GetDeploymentMetadataResponse) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[15] + 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 GetDeploymentMetadataResponse.ProtoReflect.Descriptor instead. +func (*GetDeploymentMetadataResponse) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{15} +} + +func (x *GetDeploymentMetadataResponse) GetValue() string { + if x != nil { + return x.Value + } + return "" +} + +func (x *GetDeploymentMetadataResponse) GetFound() bool { + if x != nil { + return x.Found + } + return false +} + +type PutDeploymentMetadataRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` + Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` + Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` +} + +func (x *PutDeploymentMetadataRequest) Reset() { + *x = PutDeploymentMetadataRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[16] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutDeploymentMetadataRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutDeploymentMetadataRequest) ProtoMessage() {} + +func (x *PutDeploymentMetadataRequest) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[16] + 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 PutDeploymentMetadataRequest.ProtoReflect.Descriptor instead. +func (*PutDeploymentMetadataRequest) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{16} +} + +func (x *PutDeploymentMetadataRequest) GetDeploymentId() string { + if x != nil { + return x.DeploymentId + } + return "" +} + +func (x *PutDeploymentMetadataRequest) GetKey() string { + if x != nil { + return x.Key + } + return "" +} + +func (x *PutDeploymentMetadataRequest) GetValue() string { + if x != nil { + return x.Value + } + return "" +} + +type PutDeploymentMetadataResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *PutDeploymentMetadataResponse) Reset() { + *x = PutDeploymentMetadataResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[17] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutDeploymentMetadataResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutDeploymentMetadataResponse) ProtoMessage() {} + +func (x *PutDeploymentMetadataResponse) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[17] + 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 PutDeploymentMetadataResponse.ProtoReflect.Descriptor instead. +func (*PutDeploymentMetadataResponse) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{17} +} + +type PutDeploymentMetadataMultiRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` + Metadata map[string]string `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` +} + +func (x *PutDeploymentMetadataMultiRequest) Reset() { + *x = PutDeploymentMetadataMultiRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[18] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutDeploymentMetadataMultiRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutDeploymentMetadataMultiRequest) ProtoMessage() {} + +func (x *PutDeploymentMetadataMultiRequest) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[18] + 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 PutDeploymentMetadataMultiRequest.ProtoReflect.Descriptor instead. +func (*PutDeploymentMetadataMultiRequest) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{18} +} + +func (x *PutDeploymentMetadataMultiRequest) GetDeploymentId() string { + if x != nil { + return x.DeploymentId + } + return "" +} + +func (x *PutDeploymentMetadataMultiRequest) GetMetadata() map[string]string { + if x != nil { + return x.Metadata + } + return nil +} + +type PutDeploymentMetadataMultiResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *PutDeploymentMetadataMultiResponse) Reset() { + *x = PutDeploymentMetadataMultiResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[19] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PutDeploymentMetadataMultiResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PutDeploymentMetadataMultiResponse) ProtoMessage() {} + +func (x *PutDeploymentMetadataMultiResponse) ProtoReflect() protoreflect.Message { + mi := &file_pkg_plugin_pipedservice_service_proto_msgTypes[19] + 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 PutDeploymentMetadataMultiResponse.ProtoReflect.Descriptor instead. +func (*PutDeploymentMetadataMultiResponse) Descriptor() ([]byte, []int) { + return file_pkg_plugin_pipedservice_service_proto_rawDescGZIP(), []int{19} +} + var File_pkg_plugin_pipedservice_service_proto protoreflect.FileDescriptor var file_pkg_plugin_pipedservice_service_proto_rawDesc = []byte{ @@ -544,36 +1176,165 @@ var file_pkg_plugin_pipedservice_service_proto_rawDesc = []byte{ 0x18, 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x09, 0x63, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x64, 0x22, 0x2b, 0x0a, 0x29, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x46, 0x72, 0x6f, 0x6d, 0x4c, 0x61, 0x73, 0x74, 0x43, 0x68, 0x65, 0x63, - 0x6b, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0x84, - 0x03, 0x0a, 0x0d, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, - 0x12, 0x60, 0x0a, 0x0b, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x54, 0x6f, 0x6f, 0x6c, 0x12, - 0x26, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, - 0x76, 0x69, 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x54, 0x6f, 0x6f, 0x6c, - 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, - 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, - 0x74, 0x61, 0x6c, 0x6c, 0x54, 0x6f, 0x6f, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, - 0x22, 0x00, 0x12, 0x6c, 0x0a, 0x0f, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, - 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x12, 0x2a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, - 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x72, - 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x1a, 0x2b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, - 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, - 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, - 0x12, 0xa2, 0x01, 0x0a, 0x21, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, - 0x4c, 0x6f, 0x67, 0x73, 0x46, 0x72, 0x6f, 0x6d, 0x4c, 0x61, 0x73, 0x74, 0x43, 0x68, 0x65, 0x63, - 0x6b, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x3c, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, - 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x70, 0x6f, + 0x6b, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x86, + 0x01, 0x0a, 0x17, 0x47, 0x65, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, + 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x0d, 0x64, 0x65, + 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, 0x01, 0x52, 0x0c, 0x64, 0x65, 0x70, 0x6c, + 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x22, 0x0a, 0x08, 0x73, 0x74, 0x61, 0x67, + 0x65, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, + 0x02, 0x10, 0x01, 0x52, 0x07, 0x73, 0x74, 0x61, 0x67, 0x65, 0x49, 0x64, 0x12, 0x19, 0x0a, 0x03, + 0x6b, 0x65, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, + 0x10, 0x01, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x46, 0x0a, 0x18, 0x47, 0x65, 0x74, 0x53, 0x74, + 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x66, 0x6f, 0x75, + 0x6e, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x05, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x22, + 0x9c, 0x01, 0x0a, 0x17, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, + 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x0d, 0x64, + 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, 0x01, 0x52, 0x0c, 0x64, 0x65, 0x70, + 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x22, 0x0a, 0x08, 0x73, 0x74, 0x61, + 0x67, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, + 0x72, 0x02, 0x10, 0x01, 0x52, 0x07, 0x73, 0x74, 0x61, 0x67, 0x65, 0x49, 0x64, 0x12, 0x19, 0x0a, + 0x03, 0x6b, 0x65, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, + 0x02, 0x10, 0x01, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, + 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x1a, + 0x0a, 0x18, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, + 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x89, 0x02, 0x0a, 0x1c, 0x50, + 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, + 0x75, 0x6c, 0x74, 0x69, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x0d, 0x64, + 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, 0x01, 0x52, 0x0c, 0x64, 0x65, 0x70, + 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x22, 0x0a, 0x08, 0x73, 0x74, 0x61, + 0x67, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, + 0x72, 0x02, 0x10, 0x01, 0x52, 0x07, 0x73, 0x74, 0x61, 0x67, 0x65, 0x49, 0x64, 0x12, 0x5a, 0x0a, + 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, + 0x3e, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, + 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, + 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, + 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x1a, 0x3b, 0x0a, 0x0d, 0x4d, 0x65, 0x74, + 0x61, 0x64, 0x61, 0x74, 0x61, 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, 0x1f, 0x0a, 0x1d, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, + 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x67, 0x0a, 0x1c, 0x47, 0x65, 0x74, 0x44, 0x65, + 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x0d, 0x64, 0x65, 0x70, 0x6c, 0x6f, + 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, + 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, 0x01, 0x52, 0x0c, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, + 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x19, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x02, 0x20, 0x01, + 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, 0x01, 0x52, 0x03, 0x6b, 0x65, 0x79, + 0x22, 0x4b, 0x0a, 0x1d, 0x47, 0x65, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, + 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x66, 0x6f, 0x75, 0x6e, 0x64, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x05, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x22, 0x7d, 0x0a, + 0x1c, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, + 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, + 0x0d, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, 0x01, 0x52, 0x0c, 0x64, + 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x19, 0x0a, 0x03, 0x6b, + 0x65, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, + 0x01, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, + 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x1f, 0x0a, 0x1d, + 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, + 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xef, 0x01, + 0x0a, 0x21, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, + 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x0d, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, + 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, + 0x02, 0x10, 0x01, 0x52, 0x0c, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x49, + 0x64, 0x12, 0x5f, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, + 0x03, 0x28, 0x0b, 0x32, 0x43, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, + 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, + 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, + 0x6c, 0x74, 0x69, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, + 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, + 0x74, 0x61, 0x1a, 0x3b, 0x0a, 0x0d, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 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, + 0x24, 0x0a, 0x22, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, + 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0xf6, 0x08, 0x0a, 0x0d, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, + 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x60, 0x0a, 0x0b, 0x49, 0x6e, 0x73, 0x74, 0x61, + 0x6c, 0x6c, 0x54, 0x6f, 0x6f, 0x6c, 0x12, 0x26, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, + 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, + 0x61, 0x6c, 0x6c, 0x54, 0x6f, 0x6f, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x27, + 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, + 0x69, 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x54, 0x6f, 0x6f, 0x6c, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x6c, 0x0a, 0x0f, 0x52, 0x65, 0x70, + 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x12, 0x2a, 0x2e, 0x67, + 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, + 0x65, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, + 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, + 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, + 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0xa2, 0x01, 0x0a, 0x21, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x46, 0x72, 0x6f, 0x6d, 0x4c, - 0x61, 0x73, 0x74, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3d, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, - 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, - 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, 0x46, 0x72, 0x6f, 0x6d, 0x4c, 0x61, 0x73, - 0x74, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x33, 0x5a, 0x31, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, - 0x63, 0x6f, 0x6d, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x2d, 0x63, 0x64, 0x2f, 0x70, 0x69, 0x70, 0x65, - 0x63, 0x64, 0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x2f, 0x70, 0x69, - 0x70, 0x65, 0x64, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, - 0x6f, 0x33, + 0x61, 0x73, 0x74, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x3c, 0x2e, + 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, + 0x63, 0x65, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, + 0x67, 0x73, 0x46, 0x72, 0x6f, 0x6d, 0x4c, 0x61, 0x73, 0x74, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x70, + 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3d, 0x2e, 0x67, 0x72, + 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, + 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4c, 0x6f, 0x67, 0x73, + 0x46, 0x72, 0x6f, 0x6d, 0x4c, 0x61, 0x73, 0x74, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x70, 0x6f, 0x69, + 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x6f, 0x0a, 0x10, + 0x47, 0x65, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, + 0x12, 0x2b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, + 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, + 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2c, 0x2e, + 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, + 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, + 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x6f, 0x0a, + 0x10, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, + 0x61, 0x12, 0x2b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, + 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, + 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2c, + 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, + 0x69, 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, + 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x7e, + 0x0a, 0x15, 0x50, 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, + 0x74, 0x61, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x12, 0x30, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, + 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, + 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, 0x6c, + 0x74, 0x69, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x67, 0x72, 0x70, 0x63, + 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, + 0x75, 0x74, 0x53, 0x74, 0x61, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, + 0x75, 0x6c, 0x74, 0x69, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x7e, + 0x0a, 0x15, 0x47, 0x65, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, + 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x30, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, + 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, + 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, + 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x67, 0x72, 0x70, 0x63, + 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x47, + 0x65, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, + 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x7e, + 0x0a, 0x15, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, + 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x30, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, + 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, + 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, + 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x67, 0x72, 0x70, 0x63, + 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, + 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, + 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x8d, + 0x01, 0x0a, 0x1a, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, + 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x12, 0x35, 0x2e, + 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, + 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, + 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x1a, 0x36, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x69, 0x70, 0x65, + 0x64, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x50, 0x75, 0x74, 0x44, 0x65, 0x70, + 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, + 0x75, 0x6c, 0x74, 0x69, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x33, + 0x5a, 0x31, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x70, 0x69, 0x70, + 0x65, 0x2d, 0x63, 0x64, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x63, 0x64, 0x2f, 0x70, 0x6b, 0x67, 0x2f, + 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x64, 0x73, 0x65, 0x72, 0x76, + 0x69, 0x63, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -588,7 +1349,7 @@ func file_pkg_plugin_pipedservice_service_proto_rawDescGZIP() []byte { return file_pkg_plugin_pipedservice_service_proto_rawDescData } -var file_pkg_plugin_pipedservice_service_proto_msgTypes = make([]protoimpl.MessageInfo, 8) +var file_pkg_plugin_pipedservice_service_proto_msgTypes = make([]protoimpl.MessageInfo, 22) var file_pkg_plugin_pipedservice_service_proto_goTypes = []interface{}{ (*DecryptSecretRequest)(nil), // 0: grpc.piped.service.DecryptSecretRequest (*DecryptSecretResponse)(nil), // 1: grpc.piped.service.DecryptSecretResponse @@ -598,22 +1359,50 @@ var file_pkg_plugin_pipedservice_service_proto_goTypes = []interface{}{ (*ReportStageLogsResponse)(nil), // 5: grpc.piped.service.ReportStageLogsResponse (*ReportStageLogsFromLastCheckpointRequest)(nil), // 6: grpc.piped.service.ReportStageLogsFromLastCheckpointRequest (*ReportStageLogsFromLastCheckpointResponse)(nil), // 7: grpc.piped.service.ReportStageLogsFromLastCheckpointResponse - (*model.LogBlock)(nil), // 8: model.LogBlock + (*GetStageMetadataRequest)(nil), // 8: grpc.piped.service.GetStageMetadataRequest + (*GetStageMetadataResponse)(nil), // 9: grpc.piped.service.GetStageMetadataResponse + (*PutStageMetadataRequest)(nil), // 10: grpc.piped.service.PutStageMetadataRequest + (*PutStageMetadataResponse)(nil), // 11: grpc.piped.service.PutStageMetadataResponse + (*PutStageMetadataMultiRequest)(nil), // 12: grpc.piped.service.PutStageMetadataMultiRequest + (*PutStageMetadataMultiResponse)(nil), // 13: grpc.piped.service.PutStageMetadataMultiResponse + (*GetDeploymentMetadataRequest)(nil), // 14: grpc.piped.service.GetDeploymentMetadataRequest + (*GetDeploymentMetadataResponse)(nil), // 15: grpc.piped.service.GetDeploymentMetadataResponse + (*PutDeploymentMetadataRequest)(nil), // 16: grpc.piped.service.PutDeploymentMetadataRequest + (*PutDeploymentMetadataResponse)(nil), // 17: grpc.piped.service.PutDeploymentMetadataResponse + (*PutDeploymentMetadataMultiRequest)(nil), // 18: grpc.piped.service.PutDeploymentMetadataMultiRequest + (*PutDeploymentMetadataMultiResponse)(nil), // 19: grpc.piped.service.PutDeploymentMetadataMultiResponse + nil, // 20: grpc.piped.service.PutStageMetadataMultiRequest.MetadataEntry + nil, // 21: grpc.piped.service.PutDeploymentMetadataMultiRequest.MetadataEntry + (*model.LogBlock)(nil), // 22: model.LogBlock } var file_pkg_plugin_pipedservice_service_proto_depIdxs = []int32{ - 8, // 0: grpc.piped.service.ReportStageLogsRequest.blocks:type_name -> model.LogBlock - 8, // 1: grpc.piped.service.ReportStageLogsFromLastCheckpointRequest.blocks:type_name -> model.LogBlock - 2, // 2: grpc.piped.service.PluginService.InstallTool:input_type -> grpc.piped.service.InstallToolRequest - 4, // 3: grpc.piped.service.PluginService.ReportStageLogs:input_type -> grpc.piped.service.ReportStageLogsRequest - 6, // 4: grpc.piped.service.PluginService.ReportStageLogsFromLastCheckpoint:input_type -> grpc.piped.service.ReportStageLogsFromLastCheckpointRequest - 3, // 5: grpc.piped.service.PluginService.InstallTool:output_type -> grpc.piped.service.InstallToolResponse - 5, // 6: grpc.piped.service.PluginService.ReportStageLogs:output_type -> grpc.piped.service.ReportStageLogsResponse - 7, // 7: grpc.piped.service.PluginService.ReportStageLogsFromLastCheckpoint:output_type -> grpc.piped.service.ReportStageLogsFromLastCheckpointResponse - 5, // [5:8] is the sub-list for method output_type - 2, // [2:5] is the sub-list for method input_type - 2, // [2:2] is the sub-list for extension type_name - 2, // [2:2] is the sub-list for extension extendee - 0, // [0:2] is the sub-list for field type_name + 22, // 0: grpc.piped.service.ReportStageLogsRequest.blocks:type_name -> model.LogBlock + 22, // 1: grpc.piped.service.ReportStageLogsFromLastCheckpointRequest.blocks:type_name -> model.LogBlock + 20, // 2: grpc.piped.service.PutStageMetadataMultiRequest.metadata:type_name -> grpc.piped.service.PutStageMetadataMultiRequest.MetadataEntry + 21, // 3: grpc.piped.service.PutDeploymentMetadataMultiRequest.metadata:type_name -> grpc.piped.service.PutDeploymentMetadataMultiRequest.MetadataEntry + 2, // 4: grpc.piped.service.PluginService.InstallTool:input_type -> grpc.piped.service.InstallToolRequest + 4, // 5: grpc.piped.service.PluginService.ReportStageLogs:input_type -> grpc.piped.service.ReportStageLogsRequest + 6, // 6: grpc.piped.service.PluginService.ReportStageLogsFromLastCheckpoint:input_type -> grpc.piped.service.ReportStageLogsFromLastCheckpointRequest + 8, // 7: grpc.piped.service.PluginService.GetStageMetadata:input_type -> grpc.piped.service.GetStageMetadataRequest + 10, // 8: grpc.piped.service.PluginService.PutStageMetadata:input_type -> grpc.piped.service.PutStageMetadataRequest + 12, // 9: grpc.piped.service.PluginService.PutStageMetadataMulti:input_type -> grpc.piped.service.PutStageMetadataMultiRequest + 14, // 10: grpc.piped.service.PluginService.GetDeploymentMetadata:input_type -> grpc.piped.service.GetDeploymentMetadataRequest + 16, // 11: grpc.piped.service.PluginService.PutDeploymentMetadata:input_type -> grpc.piped.service.PutDeploymentMetadataRequest + 18, // 12: grpc.piped.service.PluginService.PutDeploymentMetadataMulti:input_type -> grpc.piped.service.PutDeploymentMetadataMultiRequest + 3, // 13: grpc.piped.service.PluginService.InstallTool:output_type -> grpc.piped.service.InstallToolResponse + 5, // 14: grpc.piped.service.PluginService.ReportStageLogs:output_type -> grpc.piped.service.ReportStageLogsResponse + 7, // 15: grpc.piped.service.PluginService.ReportStageLogsFromLastCheckpoint:output_type -> grpc.piped.service.ReportStageLogsFromLastCheckpointResponse + 9, // 16: grpc.piped.service.PluginService.GetStageMetadata:output_type -> grpc.piped.service.GetStageMetadataResponse + 11, // 17: grpc.piped.service.PluginService.PutStageMetadata:output_type -> grpc.piped.service.PutStageMetadataResponse + 13, // 18: grpc.piped.service.PluginService.PutStageMetadataMulti:output_type -> grpc.piped.service.PutStageMetadataMultiResponse + 15, // 19: grpc.piped.service.PluginService.GetDeploymentMetadata:output_type -> grpc.piped.service.GetDeploymentMetadataResponse + 17, // 20: grpc.piped.service.PluginService.PutDeploymentMetadata:output_type -> grpc.piped.service.PutDeploymentMetadataResponse + 19, // 21: grpc.piped.service.PluginService.PutDeploymentMetadataMulti:output_type -> grpc.piped.service.PutDeploymentMetadataMultiResponse + 13, // [13:22] is the sub-list for method output_type + 4, // [4:13] is the sub-list for method input_type + 4, // [4:4] is the sub-list for extension type_name + 4, // [4:4] is the sub-list for extension extendee + 0, // [0:4] is the sub-list for field type_name } func init() { file_pkg_plugin_pipedservice_service_proto_init() } @@ -718,6 +1507,150 @@ func file_pkg_plugin_pipedservice_service_proto_init() { return nil } } + file_pkg_plugin_pipedservice_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetStageMetadataRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetStageMetadataResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutStageMetadataRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutStageMetadataResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutStageMetadataMultiRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutStageMetadataMultiResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetDeploymentMetadataRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetDeploymentMetadataResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutDeploymentMetadataRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutDeploymentMetadataResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutDeploymentMetadataMultiRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_plugin_pipedservice_service_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PutDeploymentMetadataMultiResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } } type x struct{} out := protoimpl.TypeBuilder{ @@ -725,7 +1658,7 @@ func file_pkg_plugin_pipedservice_service_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_pkg_plugin_pipedservice_service_proto_rawDesc, NumEnums: 0, - NumMessages: 8, + NumMessages: 22, NumExtensions: 0, NumServices: 1, }, diff --git a/pkg/plugin/pipedservice/service.pb.validate.go b/pkg/plugin/pipedservice/service.pb.validate.go index 9fff3f837f..1a44cb1933 100644 --- a/pkg/plugin/pipedservice/service.pb.validate.go +++ b/pkg/plugin/pipedservice/service.pb.validate.go @@ -1024,3 +1024,1398 @@ var _ interface { Cause() error ErrorName() string } = ReportStageLogsFromLastCheckpointResponseValidationError{} + +// Validate checks the field values on GetStageMetadataRequest with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *GetStageMetadataRequest) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on GetStageMetadataRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// GetStageMetadataRequestMultiError, or nil if none found. +func (m *GetStageMetadataRequest) ValidateAll() error { + return m.validate(true) +} + +func (m *GetStageMetadataRequest) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if utf8.RuneCountInString(m.GetDeploymentId()) < 1 { + err := GetStageMetadataRequestValidationError{ + field: "DeploymentId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if utf8.RuneCountInString(m.GetStageId()) < 1 { + err := GetStageMetadataRequestValidationError{ + field: "StageId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if utf8.RuneCountInString(m.GetKey()) < 1 { + err := GetStageMetadataRequestValidationError{ + field: "Key", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if len(errors) > 0 { + return GetStageMetadataRequestMultiError(errors) + } + + return nil +} + +// GetStageMetadataRequestMultiError is an error wrapping multiple validation +// errors returned by GetStageMetadataRequest.ValidateAll() if the designated +// constraints aren't met. +type GetStageMetadataRequestMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m GetStageMetadataRequestMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m GetStageMetadataRequestMultiError) AllErrors() []error { return m } + +// GetStageMetadataRequestValidationError is the validation error returned by +// GetStageMetadataRequest.Validate if the designated constraints aren't met. +type GetStageMetadataRequestValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e GetStageMetadataRequestValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e GetStageMetadataRequestValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e GetStageMetadataRequestValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e GetStageMetadataRequestValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e GetStageMetadataRequestValidationError) ErrorName() string { + return "GetStageMetadataRequestValidationError" +} + +// Error satisfies the builtin error interface +func (e GetStageMetadataRequestValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sGetStageMetadataRequest.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = GetStageMetadataRequestValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = GetStageMetadataRequestValidationError{} + +// Validate checks the field values on GetStageMetadataResponse with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *GetStageMetadataResponse) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on GetStageMetadataResponse with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// GetStageMetadataResponseMultiError, or nil if none found. +func (m *GetStageMetadataResponse) ValidateAll() error { + return m.validate(true) +} + +func (m *GetStageMetadataResponse) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Value + + // no validation rules for Found + + if len(errors) > 0 { + return GetStageMetadataResponseMultiError(errors) + } + + return nil +} + +// GetStageMetadataResponseMultiError is an error wrapping multiple validation +// errors returned by GetStageMetadataResponse.ValidateAll() if the designated +// constraints aren't met. +type GetStageMetadataResponseMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m GetStageMetadataResponseMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m GetStageMetadataResponseMultiError) AllErrors() []error { return m } + +// GetStageMetadataResponseValidationError is the validation error returned by +// GetStageMetadataResponse.Validate if the designated constraints aren't met. +type GetStageMetadataResponseValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e GetStageMetadataResponseValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e GetStageMetadataResponseValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e GetStageMetadataResponseValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e GetStageMetadataResponseValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e GetStageMetadataResponseValidationError) ErrorName() string { + return "GetStageMetadataResponseValidationError" +} + +// Error satisfies the builtin error interface +func (e GetStageMetadataResponseValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sGetStageMetadataResponse.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = GetStageMetadataResponseValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = GetStageMetadataResponseValidationError{} + +// Validate checks the field values on PutStageMetadataRequest with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *PutStageMetadataRequest) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutStageMetadataRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// PutStageMetadataRequestMultiError, or nil if none found. +func (m *PutStageMetadataRequest) ValidateAll() error { + return m.validate(true) +} + +func (m *PutStageMetadataRequest) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if utf8.RuneCountInString(m.GetDeploymentId()) < 1 { + err := PutStageMetadataRequestValidationError{ + field: "DeploymentId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if utf8.RuneCountInString(m.GetStageId()) < 1 { + err := PutStageMetadataRequestValidationError{ + field: "StageId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if utf8.RuneCountInString(m.GetKey()) < 1 { + err := PutStageMetadataRequestValidationError{ + field: "Key", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + // no validation rules for Value + + if len(errors) > 0 { + return PutStageMetadataRequestMultiError(errors) + } + + return nil +} + +// PutStageMetadataRequestMultiError is an error wrapping multiple validation +// errors returned by PutStageMetadataRequest.ValidateAll() if the designated +// constraints aren't met. +type PutStageMetadataRequestMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutStageMetadataRequestMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutStageMetadataRequestMultiError) AllErrors() []error { return m } + +// PutStageMetadataRequestValidationError is the validation error returned by +// PutStageMetadataRequest.Validate if the designated constraints aren't met. +type PutStageMetadataRequestValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutStageMetadataRequestValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutStageMetadataRequestValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutStageMetadataRequestValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutStageMetadataRequestValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutStageMetadataRequestValidationError) ErrorName() string { + return "PutStageMetadataRequestValidationError" +} + +// Error satisfies the builtin error interface +func (e PutStageMetadataRequestValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutStageMetadataRequest.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutStageMetadataRequestValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutStageMetadataRequestValidationError{} + +// Validate checks the field values on PutStageMetadataResponse with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *PutStageMetadataResponse) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutStageMetadataResponse with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// PutStageMetadataResponseMultiError, or nil if none found. +func (m *PutStageMetadataResponse) ValidateAll() error { + return m.validate(true) +} + +func (m *PutStageMetadataResponse) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if len(errors) > 0 { + return PutStageMetadataResponseMultiError(errors) + } + + return nil +} + +// PutStageMetadataResponseMultiError is an error wrapping multiple validation +// errors returned by PutStageMetadataResponse.ValidateAll() if the designated +// constraints aren't met. +type PutStageMetadataResponseMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutStageMetadataResponseMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutStageMetadataResponseMultiError) AllErrors() []error { return m } + +// PutStageMetadataResponseValidationError is the validation error returned by +// PutStageMetadataResponse.Validate if the designated constraints aren't met. +type PutStageMetadataResponseValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutStageMetadataResponseValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutStageMetadataResponseValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutStageMetadataResponseValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutStageMetadataResponseValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutStageMetadataResponseValidationError) ErrorName() string { + return "PutStageMetadataResponseValidationError" +} + +// Error satisfies the builtin error interface +func (e PutStageMetadataResponseValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutStageMetadataResponse.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutStageMetadataResponseValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutStageMetadataResponseValidationError{} + +// Validate checks the field values on PutStageMetadataMultiRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *PutStageMetadataMultiRequest) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutStageMetadataMultiRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// PutStageMetadataMultiRequestMultiError, or nil if none found. +func (m *PutStageMetadataMultiRequest) ValidateAll() error { + return m.validate(true) +} + +func (m *PutStageMetadataMultiRequest) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if utf8.RuneCountInString(m.GetDeploymentId()) < 1 { + err := PutStageMetadataMultiRequestValidationError{ + field: "DeploymentId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if utf8.RuneCountInString(m.GetStageId()) < 1 { + err := PutStageMetadataMultiRequestValidationError{ + field: "StageId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + // no validation rules for Metadata + + if len(errors) > 0 { + return PutStageMetadataMultiRequestMultiError(errors) + } + + return nil +} + +// PutStageMetadataMultiRequestMultiError is an error wrapping multiple +// validation errors returned by PutStageMetadataMultiRequest.ValidateAll() if +// the designated constraints aren't met. +type PutStageMetadataMultiRequestMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutStageMetadataMultiRequestMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutStageMetadataMultiRequestMultiError) AllErrors() []error { return m } + +// PutStageMetadataMultiRequestValidationError is the validation error returned +// by PutStageMetadataMultiRequest.Validate if the designated constraints +// aren't met. +type PutStageMetadataMultiRequestValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutStageMetadataMultiRequestValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutStageMetadataMultiRequestValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutStageMetadataMultiRequestValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutStageMetadataMultiRequestValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutStageMetadataMultiRequestValidationError) ErrorName() string { + return "PutStageMetadataMultiRequestValidationError" +} + +// Error satisfies the builtin error interface +func (e PutStageMetadataMultiRequestValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutStageMetadataMultiRequest.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutStageMetadataMultiRequestValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutStageMetadataMultiRequestValidationError{} + +// Validate checks the field values on PutStageMetadataMultiResponse with the +// rules defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *PutStageMetadataMultiResponse) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutStageMetadataMultiResponse with +// the rules defined in the proto definition for this message. If any rules +// are violated, the result is a list of violation errors wrapped in +// PutStageMetadataMultiResponseMultiError, or nil if none found. +func (m *PutStageMetadataMultiResponse) ValidateAll() error { + return m.validate(true) +} + +func (m *PutStageMetadataMultiResponse) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if len(errors) > 0 { + return PutStageMetadataMultiResponseMultiError(errors) + } + + return nil +} + +// PutStageMetadataMultiResponseMultiError is an error wrapping multiple +// validation errors returned by PutStageMetadataMultiResponse.ValidateAll() +// if the designated constraints aren't met. +type PutStageMetadataMultiResponseMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutStageMetadataMultiResponseMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutStageMetadataMultiResponseMultiError) AllErrors() []error { return m } + +// PutStageMetadataMultiResponseValidationError is the validation error +// returned by PutStageMetadataMultiResponse.Validate if the designated +// constraints aren't met. +type PutStageMetadataMultiResponseValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutStageMetadataMultiResponseValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutStageMetadataMultiResponseValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutStageMetadataMultiResponseValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutStageMetadataMultiResponseValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutStageMetadataMultiResponseValidationError) ErrorName() string { + return "PutStageMetadataMultiResponseValidationError" +} + +// Error satisfies the builtin error interface +func (e PutStageMetadataMultiResponseValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutStageMetadataMultiResponse.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutStageMetadataMultiResponseValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutStageMetadataMultiResponseValidationError{} + +// Validate checks the field values on GetDeploymentMetadataRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *GetDeploymentMetadataRequest) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on GetDeploymentMetadataRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// GetDeploymentMetadataRequestMultiError, or nil if none found. +func (m *GetDeploymentMetadataRequest) ValidateAll() error { + return m.validate(true) +} + +func (m *GetDeploymentMetadataRequest) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if utf8.RuneCountInString(m.GetDeploymentId()) < 1 { + err := GetDeploymentMetadataRequestValidationError{ + field: "DeploymentId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if utf8.RuneCountInString(m.GetKey()) < 1 { + err := GetDeploymentMetadataRequestValidationError{ + field: "Key", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if len(errors) > 0 { + return GetDeploymentMetadataRequestMultiError(errors) + } + + return nil +} + +// GetDeploymentMetadataRequestMultiError is an error wrapping multiple +// validation errors returned by GetDeploymentMetadataRequest.ValidateAll() if +// the designated constraints aren't met. +type GetDeploymentMetadataRequestMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m GetDeploymentMetadataRequestMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m GetDeploymentMetadataRequestMultiError) AllErrors() []error { return m } + +// GetDeploymentMetadataRequestValidationError is the validation error returned +// by GetDeploymentMetadataRequest.Validate if the designated constraints +// aren't met. +type GetDeploymentMetadataRequestValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e GetDeploymentMetadataRequestValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e GetDeploymentMetadataRequestValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e GetDeploymentMetadataRequestValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e GetDeploymentMetadataRequestValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e GetDeploymentMetadataRequestValidationError) ErrorName() string { + return "GetDeploymentMetadataRequestValidationError" +} + +// Error satisfies the builtin error interface +func (e GetDeploymentMetadataRequestValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sGetDeploymentMetadataRequest.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = GetDeploymentMetadataRequestValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = GetDeploymentMetadataRequestValidationError{} + +// Validate checks the field values on GetDeploymentMetadataResponse with the +// rules defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *GetDeploymentMetadataResponse) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on GetDeploymentMetadataResponse with +// the rules defined in the proto definition for this message. If any rules +// are violated, the result is a list of violation errors wrapped in +// GetDeploymentMetadataResponseMultiError, or nil if none found. +func (m *GetDeploymentMetadataResponse) ValidateAll() error { + return m.validate(true) +} + +func (m *GetDeploymentMetadataResponse) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Value + + // no validation rules for Found + + if len(errors) > 0 { + return GetDeploymentMetadataResponseMultiError(errors) + } + + return nil +} + +// GetDeploymentMetadataResponseMultiError is an error wrapping multiple +// validation errors returned by GetDeploymentMetadataResponse.ValidateAll() +// if the designated constraints aren't met. +type GetDeploymentMetadataResponseMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m GetDeploymentMetadataResponseMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m GetDeploymentMetadataResponseMultiError) AllErrors() []error { return m } + +// GetDeploymentMetadataResponseValidationError is the validation error +// returned by GetDeploymentMetadataResponse.Validate if the designated +// constraints aren't met. +type GetDeploymentMetadataResponseValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e GetDeploymentMetadataResponseValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e GetDeploymentMetadataResponseValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e GetDeploymentMetadataResponseValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e GetDeploymentMetadataResponseValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e GetDeploymentMetadataResponseValidationError) ErrorName() string { + return "GetDeploymentMetadataResponseValidationError" +} + +// Error satisfies the builtin error interface +func (e GetDeploymentMetadataResponseValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sGetDeploymentMetadataResponse.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = GetDeploymentMetadataResponseValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = GetDeploymentMetadataResponseValidationError{} + +// Validate checks the field values on PutDeploymentMetadataRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *PutDeploymentMetadataRequest) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutDeploymentMetadataRequest with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// PutDeploymentMetadataRequestMultiError, or nil if none found. +func (m *PutDeploymentMetadataRequest) ValidateAll() error { + return m.validate(true) +} + +func (m *PutDeploymentMetadataRequest) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if utf8.RuneCountInString(m.GetDeploymentId()) < 1 { + err := PutDeploymentMetadataRequestValidationError{ + field: "DeploymentId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + if utf8.RuneCountInString(m.GetKey()) < 1 { + err := PutDeploymentMetadataRequestValidationError{ + field: "Key", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + // no validation rules for Value + + if len(errors) > 0 { + return PutDeploymentMetadataRequestMultiError(errors) + } + + return nil +} + +// PutDeploymentMetadataRequestMultiError is an error wrapping multiple +// validation errors returned by PutDeploymentMetadataRequest.ValidateAll() if +// the designated constraints aren't met. +type PutDeploymentMetadataRequestMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutDeploymentMetadataRequestMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutDeploymentMetadataRequestMultiError) AllErrors() []error { return m } + +// PutDeploymentMetadataRequestValidationError is the validation error returned +// by PutDeploymentMetadataRequest.Validate if the designated constraints +// aren't met. +type PutDeploymentMetadataRequestValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutDeploymentMetadataRequestValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutDeploymentMetadataRequestValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutDeploymentMetadataRequestValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutDeploymentMetadataRequestValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutDeploymentMetadataRequestValidationError) ErrorName() string { + return "PutDeploymentMetadataRequestValidationError" +} + +// Error satisfies the builtin error interface +func (e PutDeploymentMetadataRequestValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutDeploymentMetadataRequest.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutDeploymentMetadataRequestValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutDeploymentMetadataRequestValidationError{} + +// Validate checks the field values on PutDeploymentMetadataResponse with the +// rules defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *PutDeploymentMetadataResponse) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutDeploymentMetadataResponse with +// the rules defined in the proto definition for this message. If any rules +// are violated, the result is a list of violation errors wrapped in +// PutDeploymentMetadataResponseMultiError, or nil if none found. +func (m *PutDeploymentMetadataResponse) ValidateAll() error { + return m.validate(true) +} + +func (m *PutDeploymentMetadataResponse) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if len(errors) > 0 { + return PutDeploymentMetadataResponseMultiError(errors) + } + + return nil +} + +// PutDeploymentMetadataResponseMultiError is an error wrapping multiple +// validation errors returned by PutDeploymentMetadataResponse.ValidateAll() +// if the designated constraints aren't met. +type PutDeploymentMetadataResponseMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutDeploymentMetadataResponseMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutDeploymentMetadataResponseMultiError) AllErrors() []error { return m } + +// PutDeploymentMetadataResponseValidationError is the validation error +// returned by PutDeploymentMetadataResponse.Validate if the designated +// constraints aren't met. +type PutDeploymentMetadataResponseValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutDeploymentMetadataResponseValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutDeploymentMetadataResponseValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutDeploymentMetadataResponseValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutDeploymentMetadataResponseValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutDeploymentMetadataResponseValidationError) ErrorName() string { + return "PutDeploymentMetadataResponseValidationError" +} + +// Error satisfies the builtin error interface +func (e PutDeploymentMetadataResponseValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutDeploymentMetadataResponse.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutDeploymentMetadataResponseValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutDeploymentMetadataResponseValidationError{} + +// Validate checks the field values on PutDeploymentMetadataMultiRequest with +// the rules defined in the proto definition for this message. If any rules +// are violated, the first error encountered is returned, or nil if there are +// no violations. +func (m *PutDeploymentMetadataMultiRequest) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutDeploymentMetadataMultiRequest +// with the rules defined in the proto definition for this message. If any +// rules are violated, the result is a list of violation errors wrapped in +// PutDeploymentMetadataMultiRequestMultiError, or nil if none found. +func (m *PutDeploymentMetadataMultiRequest) ValidateAll() error { + return m.validate(true) +} + +func (m *PutDeploymentMetadataMultiRequest) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if utf8.RuneCountInString(m.GetDeploymentId()) < 1 { + err := PutDeploymentMetadataMultiRequestValidationError{ + field: "DeploymentId", + reason: "value length must be at least 1 runes", + } + if !all { + return err + } + errors = append(errors, err) + } + + // no validation rules for Metadata + + if len(errors) > 0 { + return PutDeploymentMetadataMultiRequestMultiError(errors) + } + + return nil +} + +// PutDeploymentMetadataMultiRequestMultiError is an error wrapping multiple +// validation errors returned by +// PutDeploymentMetadataMultiRequest.ValidateAll() if the designated +// constraints aren't met. +type PutDeploymentMetadataMultiRequestMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutDeploymentMetadataMultiRequestMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutDeploymentMetadataMultiRequestMultiError) AllErrors() []error { return m } + +// PutDeploymentMetadataMultiRequestValidationError is the validation error +// returned by PutDeploymentMetadataMultiRequest.Validate if the designated +// constraints aren't met. +type PutDeploymentMetadataMultiRequestValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutDeploymentMetadataMultiRequestValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutDeploymentMetadataMultiRequestValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutDeploymentMetadataMultiRequestValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutDeploymentMetadataMultiRequestValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutDeploymentMetadataMultiRequestValidationError) ErrorName() string { + return "PutDeploymentMetadataMultiRequestValidationError" +} + +// Error satisfies the builtin error interface +func (e PutDeploymentMetadataMultiRequestValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutDeploymentMetadataMultiRequest.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutDeploymentMetadataMultiRequestValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutDeploymentMetadataMultiRequestValidationError{} + +// Validate checks the field values on PutDeploymentMetadataMultiResponse with +// the rules defined in the proto definition for this message. If any rules +// are violated, the first error encountered is returned, or nil if there are +// no violations. +func (m *PutDeploymentMetadataMultiResponse) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PutDeploymentMetadataMultiResponse +// with the rules defined in the proto definition for this message. If any +// rules are violated, the result is a list of violation errors wrapped in +// PutDeploymentMetadataMultiResponseMultiError, or nil if none found. +func (m *PutDeploymentMetadataMultiResponse) ValidateAll() error { + return m.validate(true) +} + +func (m *PutDeploymentMetadataMultiResponse) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + if len(errors) > 0 { + return PutDeploymentMetadataMultiResponseMultiError(errors) + } + + return nil +} + +// PutDeploymentMetadataMultiResponseMultiError is an error wrapping multiple +// validation errors returned by +// PutDeploymentMetadataMultiResponse.ValidateAll() if the designated +// constraints aren't met. +type PutDeploymentMetadataMultiResponseMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PutDeploymentMetadataMultiResponseMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PutDeploymentMetadataMultiResponseMultiError) AllErrors() []error { return m } + +// PutDeploymentMetadataMultiResponseValidationError is the validation error +// returned by PutDeploymentMetadataMultiResponse.Validate if the designated +// constraints aren't met. +type PutDeploymentMetadataMultiResponseValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PutDeploymentMetadataMultiResponseValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PutDeploymentMetadataMultiResponseValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PutDeploymentMetadataMultiResponseValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PutDeploymentMetadataMultiResponseValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PutDeploymentMetadataMultiResponseValidationError) ErrorName() string { + return "PutDeploymentMetadataMultiResponseValidationError" +} + +// Error satisfies the builtin error interface +func (e PutDeploymentMetadataMultiResponseValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPutDeploymentMetadataMultiResponse.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PutDeploymentMetadataMultiResponseValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PutDeploymentMetadataMultiResponseValidationError{} diff --git a/pkg/plugin/pipedservice/service.proto b/pkg/plugin/pipedservice/service.proto index 5555bd708f..89819ba8f3 100644 --- a/pkg/plugin/pipedservice/service.proto +++ b/pkg/plugin/pipedservice/service.proto @@ -29,6 +29,19 @@ service PluginService { rpc ReportStageLogs(ReportStageLogsRequest) returns (ReportStageLogsResponse) {} // ReportStageLogsFromLastCheckpoint is used to save the full logs from the most recently saved point. rpc ReportStageLogsFromLastCheckpoint(ReportStageLogsFromLastCheckpointRequest) returns (ReportStageLogsFromLastCheckpointResponse) {} + + // GetStageMetadata gets one metadata value of the given stage. + rpc GetStageMetadata(GetStageMetadataRequest) returns (GetStageMetadataResponse) {} + // PutStageMetadata puts one metadata of the given stage. + rpc PutStageMetadata(PutStageMetadataRequest) returns (PutStageMetadataResponse) {} + // PutStageMetadataMulti puts the metadata pairs of the given stage. + rpc PutStageMetadataMulti(PutStageMetadataMultiRequest) returns (PutStageMetadataMultiResponse) {} + // GetDeploymentMetadata gets one metadata value of the given deployment. + rpc GetDeploymentMetadata(GetDeploymentMetadataRequest) returns (GetDeploymentMetadataResponse) {} + // PutDeploymentMetadata puts one metadata of the given deployment. + rpc PutDeploymentMetadata(PutDeploymentMetadataRequest) returns (PutDeploymentMetadataResponse) {} + // PutDeploymentMetadataMulti puts the metadata pairs of the given deployment. + rpc PutDeploymentMetadataMulti(PutDeploymentMetadataMultiRequest) returns (PutDeploymentMetadataMultiResponse) {} } message DecryptSecretRequest { @@ -87,3 +100,60 @@ message ReportStageLogsFromLastCheckpointRequest { message ReportStageLogsFromLastCheckpointResponse { } + +message GetStageMetadataRequest { + string deployment_id = 1 [(validate.rules).string.min_len = 1]; + string stage_id = 2 [(validate.rules).string.min_len = 1]; + string key = 3 [(validate.rules).string.min_len = 1]; +} + +message GetStageMetadataResponse { + string value = 1; + bool found = 2; +} + +message PutStageMetadataRequest { + string deployment_id = 1 [(validate.rules).string.min_len = 1]; + string stage_id = 2 [(validate.rules).string.min_len = 1]; + string key = 3 [(validate.rules).string.min_len = 1]; + string value = 4; +} + +message PutStageMetadataResponse { +} + +message PutStageMetadataMultiRequest { + string deployment_id = 1 [(validate.rules).string.min_len = 1]; + string stage_id = 2 [(validate.rules).string.min_len = 1]; + map metadata = 3; +} + +message PutStageMetadataMultiResponse { +} + +message GetDeploymentMetadataRequest { + string deployment_id = 1 [(validate.rules).string.min_len = 1]; + string key = 2 [(validate.rules).string.min_len = 1]; +} + +message GetDeploymentMetadataResponse { + string value = 1; + bool found = 2; +} + +message PutDeploymentMetadataRequest { + string deployment_id = 1 [(validate.rules).string.min_len = 1]; + string key = 2 [(validate.rules).string.min_len = 1]; + string value = 3; +} + +message PutDeploymentMetadataResponse { +} + +message PutDeploymentMetadataMultiRequest { + string deployment_id = 1 [(validate.rules).string.min_len = 1]; + map metadata = 2; +} + +message PutDeploymentMetadataMultiResponse { +} diff --git a/pkg/plugin/pipedservice/service_grpc.pb.go b/pkg/plugin/pipedservice/service_grpc.pb.go index a4ebedf544..0172e9b4bc 100644 --- a/pkg/plugin/pipedservice/service_grpc.pb.go +++ b/pkg/plugin/pipedservice/service_grpc.pb.go @@ -29,6 +29,18 @@ type PluginServiceClient interface { ReportStageLogs(ctx context.Context, in *ReportStageLogsRequest, opts ...grpc.CallOption) (*ReportStageLogsResponse, error) // ReportStageLogsFromLastCheckpoint is used to save the full logs from the most recently saved point. ReportStageLogsFromLastCheckpoint(ctx context.Context, in *ReportStageLogsFromLastCheckpointRequest, opts ...grpc.CallOption) (*ReportStageLogsFromLastCheckpointResponse, error) + // GetStageMetadata gets one metadata value of the given stage. + GetStageMetadata(ctx context.Context, in *GetStageMetadataRequest, opts ...grpc.CallOption) (*GetStageMetadataResponse, error) + // PutStageMetadata puts one metadata of the given stage. + PutStageMetadata(ctx context.Context, in *PutStageMetadataRequest, opts ...grpc.CallOption) (*PutStageMetadataResponse, error) + // PutStageMetadataMulti puts the metadata pairs of the given stage. + PutStageMetadataMulti(ctx context.Context, in *PutStageMetadataMultiRequest, opts ...grpc.CallOption) (*PutStageMetadataMultiResponse, error) + // GetDeploymentMetadata gets one metadata value of the given deployment. + GetDeploymentMetadata(ctx context.Context, in *GetDeploymentMetadataRequest, opts ...grpc.CallOption) (*GetDeploymentMetadataResponse, error) + // PutDeploymentMetadata puts one metadata of the given deployment. + PutDeploymentMetadata(ctx context.Context, in *PutDeploymentMetadataRequest, opts ...grpc.CallOption) (*PutDeploymentMetadataResponse, error) + // PutDeploymentMetadataMulti puts the metadata pairs of the given deployment. + PutDeploymentMetadataMulti(ctx context.Context, in *PutDeploymentMetadataMultiRequest, opts ...grpc.CallOption) (*PutDeploymentMetadataMultiResponse, error) } type pluginServiceClient struct { @@ -66,6 +78,60 @@ func (c *pluginServiceClient) ReportStageLogsFromLastCheckpoint(ctx context.Cont return out, nil } +func (c *pluginServiceClient) GetStageMetadata(ctx context.Context, in *GetStageMetadataRequest, opts ...grpc.CallOption) (*GetStageMetadataResponse, error) { + out := new(GetStageMetadataResponse) + err := c.cc.Invoke(ctx, "/grpc.piped.service.PluginService/GetStageMetadata", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *pluginServiceClient) PutStageMetadata(ctx context.Context, in *PutStageMetadataRequest, opts ...grpc.CallOption) (*PutStageMetadataResponse, error) { + out := new(PutStageMetadataResponse) + err := c.cc.Invoke(ctx, "/grpc.piped.service.PluginService/PutStageMetadata", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *pluginServiceClient) PutStageMetadataMulti(ctx context.Context, in *PutStageMetadataMultiRequest, opts ...grpc.CallOption) (*PutStageMetadataMultiResponse, error) { + out := new(PutStageMetadataMultiResponse) + err := c.cc.Invoke(ctx, "/grpc.piped.service.PluginService/PutStageMetadataMulti", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *pluginServiceClient) GetDeploymentMetadata(ctx context.Context, in *GetDeploymentMetadataRequest, opts ...grpc.CallOption) (*GetDeploymentMetadataResponse, error) { + out := new(GetDeploymentMetadataResponse) + err := c.cc.Invoke(ctx, "/grpc.piped.service.PluginService/GetDeploymentMetadata", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *pluginServiceClient) PutDeploymentMetadata(ctx context.Context, in *PutDeploymentMetadataRequest, opts ...grpc.CallOption) (*PutDeploymentMetadataResponse, error) { + out := new(PutDeploymentMetadataResponse) + err := c.cc.Invoke(ctx, "/grpc.piped.service.PluginService/PutDeploymentMetadata", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *pluginServiceClient) PutDeploymentMetadataMulti(ctx context.Context, in *PutDeploymentMetadataMultiRequest, opts ...grpc.CallOption) (*PutDeploymentMetadataMultiResponse, error) { + out := new(PutDeploymentMetadataMultiResponse) + err := c.cc.Invoke(ctx, "/grpc.piped.service.PluginService/PutDeploymentMetadataMulti", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // PluginServiceServer is the server API for PluginService service. // All implementations must embed UnimplementedPluginServiceServer // for forward compatibility @@ -77,6 +143,18 @@ type PluginServiceServer interface { ReportStageLogs(context.Context, *ReportStageLogsRequest) (*ReportStageLogsResponse, error) // ReportStageLogsFromLastCheckpoint is used to save the full logs from the most recently saved point. ReportStageLogsFromLastCheckpoint(context.Context, *ReportStageLogsFromLastCheckpointRequest) (*ReportStageLogsFromLastCheckpointResponse, error) + // GetStageMetadata gets one metadata value of the given stage. + GetStageMetadata(context.Context, *GetStageMetadataRequest) (*GetStageMetadataResponse, error) + // PutStageMetadata puts one metadata of the given stage. + PutStageMetadata(context.Context, *PutStageMetadataRequest) (*PutStageMetadataResponse, error) + // PutStageMetadataMulti puts the metadata pairs of the given stage. + PutStageMetadataMulti(context.Context, *PutStageMetadataMultiRequest) (*PutStageMetadataMultiResponse, error) + // GetDeploymentMetadata gets one metadata value of the given deployment. + GetDeploymentMetadata(context.Context, *GetDeploymentMetadataRequest) (*GetDeploymentMetadataResponse, error) + // PutDeploymentMetadata puts one metadata of the given deployment. + PutDeploymentMetadata(context.Context, *PutDeploymentMetadataRequest) (*PutDeploymentMetadataResponse, error) + // PutDeploymentMetadataMulti puts the metadata pairs of the given deployment. + PutDeploymentMetadataMulti(context.Context, *PutDeploymentMetadataMultiRequest) (*PutDeploymentMetadataMultiResponse, error) mustEmbedUnimplementedPluginServiceServer() } @@ -93,6 +171,24 @@ func (UnimplementedPluginServiceServer) ReportStageLogs(context.Context, *Report func (UnimplementedPluginServiceServer) ReportStageLogsFromLastCheckpoint(context.Context, *ReportStageLogsFromLastCheckpointRequest) (*ReportStageLogsFromLastCheckpointResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method ReportStageLogsFromLastCheckpoint not implemented") } +func (UnimplementedPluginServiceServer) GetStageMetadata(context.Context, *GetStageMetadataRequest) (*GetStageMetadataResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetStageMetadata not implemented") +} +func (UnimplementedPluginServiceServer) PutStageMetadata(context.Context, *PutStageMetadataRequest) (*PutStageMetadataResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method PutStageMetadata not implemented") +} +func (UnimplementedPluginServiceServer) PutStageMetadataMulti(context.Context, *PutStageMetadataMultiRequest) (*PutStageMetadataMultiResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method PutStageMetadataMulti not implemented") +} +func (UnimplementedPluginServiceServer) GetDeploymentMetadata(context.Context, *GetDeploymentMetadataRequest) (*GetDeploymentMetadataResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetDeploymentMetadata not implemented") +} +func (UnimplementedPluginServiceServer) PutDeploymentMetadata(context.Context, *PutDeploymentMetadataRequest) (*PutDeploymentMetadataResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method PutDeploymentMetadata not implemented") +} +func (UnimplementedPluginServiceServer) PutDeploymentMetadataMulti(context.Context, *PutDeploymentMetadataMultiRequest) (*PutDeploymentMetadataMultiResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method PutDeploymentMetadataMulti not implemented") +} func (UnimplementedPluginServiceServer) mustEmbedUnimplementedPluginServiceServer() {} // UnsafePluginServiceServer may be embedded to opt out of forward compatibility for this service. @@ -160,6 +256,114 @@ func _PluginService_ReportStageLogsFromLastCheckpoint_Handler(srv interface{}, c return interceptor(ctx, in, info, handler) } +func _PluginService_GetStageMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetStageMetadataRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PluginServiceServer).GetStageMetadata(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/grpc.piped.service.PluginService/GetStageMetadata", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PluginServiceServer).GetStageMetadata(ctx, req.(*GetStageMetadataRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _PluginService_PutStageMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(PutStageMetadataRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PluginServiceServer).PutStageMetadata(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/grpc.piped.service.PluginService/PutStageMetadata", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PluginServiceServer).PutStageMetadata(ctx, req.(*PutStageMetadataRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _PluginService_PutStageMetadataMulti_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(PutStageMetadataMultiRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PluginServiceServer).PutStageMetadataMulti(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/grpc.piped.service.PluginService/PutStageMetadataMulti", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PluginServiceServer).PutStageMetadataMulti(ctx, req.(*PutStageMetadataMultiRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _PluginService_GetDeploymentMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetDeploymentMetadataRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PluginServiceServer).GetDeploymentMetadata(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/grpc.piped.service.PluginService/GetDeploymentMetadata", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PluginServiceServer).GetDeploymentMetadata(ctx, req.(*GetDeploymentMetadataRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _PluginService_PutDeploymentMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(PutDeploymentMetadataRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PluginServiceServer).PutDeploymentMetadata(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/grpc.piped.service.PluginService/PutDeploymentMetadata", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PluginServiceServer).PutDeploymentMetadata(ctx, req.(*PutDeploymentMetadataRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _PluginService_PutDeploymentMetadataMulti_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(PutDeploymentMetadataMultiRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PluginServiceServer).PutDeploymentMetadataMulti(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/grpc.piped.service.PluginService/PutDeploymentMetadataMulti", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PluginServiceServer).PutDeploymentMetadataMulti(ctx, req.(*PutDeploymentMetadataMultiRequest)) + } + return interceptor(ctx, in, info, handler) +} + // PluginService_ServiceDesc is the grpc.ServiceDesc for PluginService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -179,6 +383,30 @@ var PluginService_ServiceDesc = grpc.ServiceDesc{ MethodName: "ReportStageLogsFromLastCheckpoint", Handler: _PluginService_ReportStageLogsFromLastCheckpoint_Handler, }, + { + MethodName: "GetStageMetadata", + Handler: _PluginService_GetStageMetadata_Handler, + }, + { + MethodName: "PutStageMetadata", + Handler: _PluginService_PutStageMetadata_Handler, + }, + { + MethodName: "PutStageMetadataMulti", + Handler: _PluginService_PutStageMetadataMulti_Handler, + }, + { + MethodName: "GetDeploymentMetadata", + Handler: _PluginService_GetDeploymentMetadata_Handler, + }, + { + MethodName: "PutDeploymentMetadata", + Handler: _PluginService_PutDeploymentMetadata_Handler, + }, + { + MethodName: "PutDeploymentMetadataMulti", + Handler: _PluginService_PutDeploymentMetadataMulti_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/plugin/pipedservice/service.proto",