From 4654f1f00fe203584a2124c37cb342940c55fe72 Mon Sep 17 00:00:00 2001 From: Ben Knoll Date: Thu, 3 Oct 2024 12:34:46 -0500 Subject: [PATCH] Release 1.4.3 (#624) * Release 1.4.3 * Fixing Go --- go/go.mod | 1 + go/go.sum | 2 + go/mtap/api/v1/events.pb.go | 36 +++++++------- go/mtap/api/v1/events.swagger.json | 6 +-- go/mtap/api/v1/events_grpc.pb.go | 2 +- go/mtap/api/v1/pipeline.pb.go | 46 ++++++++--------- go/mtap/api/v1/pipeline.swagger.json | 2 +- go/mtap/api/v1/pipeline_grpc.pb.go | 2 +- go/mtap/api/v1/processing.pb.go | 68 +++++++++++++------------- go/mtap/api/v1/processing.swagger.json | 2 +- go/mtap/api/v1/processing_grpc.pb.go | 2 +- 11 files changed, 86 insertions(+), 83 deletions(-) diff --git a/go/go.mod b/go/go.mod index 783f6153..9b445f1f 100644 --- a/go/go.mod +++ b/go/go.mod @@ -6,6 +6,7 @@ toolchain go1.22.1 require ( github.com/golang/glog v1.2.2 + github.com/golang/protobuf v1.5.4 github.com/gorilla/mux v1.8.1 github.com/grpc-ecosystem/grpc-gateway/v2 v2.22.0 github.com/spf13/cast v1.7.0 diff --git a/go/go.sum b/go/go.sum index 50b6d2e8..efedf4a0 100644 --- a/go/go.sum +++ b/go/go.sum @@ -8,6 +8,8 @@ github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nos github.com/fsnotify/fsnotify v1.7.0/go.mod h1:40Bi/Hjc2AVfZrqy+aj+yEI+/bRxZnMJyTJwOpGvigM= github.com/golang/glog v1.2.2 h1:1+mZ9upx1Dh6FmUTFR1naJ77miKiXgALjWOZ3NVFPmY= github.com/golang/glog v1.2.2/go.mod h1:6AhwSGph0fcJtXVM/PEHPqZlFeoLxhs7/t5UDAwmO+w= +github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= +github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY= diff --git a/go/mtap/api/v1/events.pb.go b/go/mtap/api/v1/events.pb.go index 17b1a451..5e8bd3b0 100644 --- a/go/mtap/api/v1/events.pb.go +++ b/go/mtap/api/v1/events.pb.go @@ -17,19 +17,19 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v5.26.1 +// protoc-gen-go v1.31.0 +// protoc v3.12.4 // source: mtap/api/v1/events.proto package v1 import ( + any1 "github.com/golang/protobuf/ptypes/any" + duration "github.com/golang/protobuf/ptypes/duration" + _struct "github.com/golang/protobuf/ptypes/struct" _ "google.golang.org/genproto/googleapis/api/annotations" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" - anypb "google.golang.org/protobuf/types/known/anypb" - durationpb "google.golang.org/protobuf/types/known/durationpb" - structpb "google.golang.org/protobuf/types/known/structpb" reflect "reflect" sync "sync" ) @@ -192,7 +192,7 @@ type OpenEventRequest struct { // Only create a new event, failing if the event already exists. OnlyCreateNew bool `protobuf:"varint,2,opt,name=only_create_new,json=onlyCreateNew,proto3" json:"only_create_new,omitempty"` // Optional, how long the lease is valid for. - LeaseDuration *durationpb.Duration `protobuf:"bytes,3,opt,name=lease_duration,json=leaseDuration,proto3" json:"lease_duration,omitempty"` + LeaseDuration *duration.Duration `protobuf:"bytes,3,opt,name=lease_duration,json=leaseDuration,proto3" json:"lease_duration,omitempty"` } func (x *OpenEventRequest) Reset() { @@ -241,7 +241,7 @@ func (x *OpenEventRequest) GetOnlyCreateNew() bool { return false } -func (x *OpenEventRequest) GetLeaseDuration() *durationpb.Duration { +func (x *OpenEventRequest) GetLeaseDuration() *duration.Duration { if x != nil { return x.LeaseDuration } @@ -1437,7 +1437,7 @@ func (x *AddLabelsRequest) GetGenericLabels() *GenericLabels { return nil } -func (x *AddLabelsRequest) GetCustomLabels() *anypb.Any { +func (x *AddLabelsRequest) GetCustomLabels() *any1.Any { if x, ok := x.GetLabels().(*AddLabelsRequest_CustomLabels); ok { return x.CustomLabels } @@ -1465,7 +1465,7 @@ type AddLabelsRequest_GenericLabels struct { type AddLabelsRequest_CustomLabels struct { // Experimental, a different type of serialized message, which the Events // service will store and return directly to clients. - CustomLabels *anypb.Any `protobuf:"bytes,5,opt,name=custom_labels,json=customLabels,proto3,oneof"` + CustomLabels *any1.Any `protobuf:"bytes,5,opt,name=custom_labels,json=customLabels,proto3,oneof"` } func (*AddLabelsRequest_GenericLabels) isAddLabelsRequest_Labels() {} @@ -1652,9 +1652,9 @@ type GenericLabel struct { // The end offset of the label relative to the document. EndIndex uint32 `protobuf:"varint,3,opt,name=end_index,json=endIndex,proto3" json:"end_index,omitempty"` // A structure containing the dynamic primitive fields of the label. - Fields *structpb.Struct `protobuf:"bytes,4,opt,name=fields,proto3" json:"fields,omitempty"` + Fields *_struct.Struct `protobuf:"bytes,4,opt,name=fields,proto3" json:"fields,omitempty"` // A structure containing the reference fields of the label. - ReferenceIds *structpb.Struct `protobuf:"bytes,5,opt,name=reference_ids,json=referenceIds,proto3" json:"reference_ids,omitempty"` + ReferenceIds *_struct.Struct `protobuf:"bytes,5,opt,name=reference_ids,json=referenceIds,proto3" json:"reference_ids,omitempty"` } func (x *GenericLabel) Reset() { @@ -1710,14 +1710,14 @@ func (x *GenericLabel) GetEndIndex() uint32 { return 0 } -func (x *GenericLabel) GetFields() *structpb.Struct { +func (x *GenericLabel) GetFields() *_struct.Struct { if x != nil { return x.Fields } return nil } -func (x *GenericLabel) GetReferenceIds() *structpb.Struct { +func (x *GenericLabel) GetReferenceIds() *_struct.Struct { if x != nil { return x.ReferenceIds } @@ -1785,7 +1785,7 @@ func (x *GetLabelsResponse) GetGenericLabels() *GenericLabels { return nil } -func (x *GetLabelsResponse) GetCustomLabels() *anypb.Any { +func (x *GetLabelsResponse) GetCustomLabels() *any1.Any { if x, ok := x.GetLabels().(*GetLabelsResponse_CustomLabels); ok { return x.CustomLabels } @@ -1803,7 +1803,7 @@ type GetLabelsResponse_GenericLabels struct { type GetLabelsResponse_CustomLabels struct { // If the original were other_labels. - CustomLabels *anypb.Any `protobuf:"bytes,2,opt,name=custom_labels,json=customLabels,proto3,oneof"` + CustomLabels *any1.Any `protobuf:"bytes,2,opt,name=custom_labels,json=customLabels,proto3,oneof"` } func (*GetLabelsResponse_GenericLabels) isGetLabelsResponse_Labels() {} @@ -2243,9 +2243,9 @@ var file_mtap_api_v1_events_proto_goTypes = []interface{}{ (*GetLabelsResponse)(nil), // 30: mtap.api.v1.GetLabelsResponse nil, // 31: mtap.api.v1.GetAllMetadataResponse.MetadataEntry (*GetLabelIndicesInfoResponse_LabelIndexInfo)(nil), // 32: mtap.api.v1.GetLabelIndicesInfoResponse.LabelIndexInfo - (*durationpb.Duration)(nil), // 33: google.protobuf.Duration - (*anypb.Any)(nil), // 34: google.protobuf.Any - (*structpb.Struct)(nil), // 35: google.protobuf.Struct + (*duration.Duration)(nil), // 33: google.protobuf.Duration + (*any1.Any)(nil), // 34: google.protobuf.Any + (*_struct.Struct)(nil), // 35: google.protobuf.Struct } var file_mtap_api_v1_events_proto_depIdxs = []int32{ 33, // 0: mtap.api.v1.OpenEventRequest.lease_duration:type_name -> google.protobuf.Duration diff --git a/go/mtap/api/v1/events.swagger.json b/go/mtap/api/v1/events.swagger.json index 33ad18fa..8a710a71 100644 --- a/go/mtap/api/v1/events.swagger.json +++ b/go/mtap/api/v1/events.swagger.json @@ -638,11 +638,11 @@ "properties": { "@type": { "type": "string", - "description": "A URL/resource name that uniquely identifies the type of the serialized\nprotocol buffer message. This string must contain at least\none \"/\" character. The last segment of the URL's path must represent\nthe fully qualified name of the type (as in\n`path/google.protobuf.Duration`). The name should be in a canonical form\n(e.g., leading \".\" is not accepted).\n\nIn practice, teams usually precompile into the binary all types that they\nexpect it to use in the context of Any. However, for URLs which use the\nscheme `http`, `https`, or no scheme, one can optionally set up a type\nserver that maps type URLs to message definitions as follows:\n\n* If no scheme is provided, `https` is assumed.\n* An HTTP GET on the URL must yield a [google.protobuf.Type][]\n value in binary format, or produce an error.\n* Applications are allowed to cache lookup results based on the\n URL, or have them precompiled into a binary to avoid any\n lookup. Therefore, binary compatibility needs to be preserved\n on changes to types. (Use versioned type names to manage\n breaking changes.)\n\nNote: this functionality is not currently available in the official\nprotobuf release, and it is not used for type URLs beginning with\ntype.googleapis.com. As of May 2023, there are no widely used type server\nimplementations and no plans to implement one.\n\nSchemes other than `http`, `https` (or the empty scheme) might be\nused with implementation specific semantics." + "description": "A URL/resource name that uniquely identifies the type of the serialized\nprotocol buffer message. This string must contain at least\none \"/\" character. The last segment of the URL's path must represent\nthe fully qualified name of the type (as in\n`path/google.protobuf.Duration`). The name should be in a canonical form\n(e.g., leading \".\" is not accepted).\n\nIn practice, teams usually precompile into the binary all types that they\nexpect it to use in the context of Any. However, for URLs which use the\nscheme `http`, `https`, or no scheme, one can optionally set up a type\nserver that maps type URLs to message definitions as follows:\n\n* If no scheme is provided, `https` is assumed.\n* An HTTP GET on the URL must yield a [google.protobuf.Type][]\n value in binary format, or produce an error.\n* Applications are allowed to cache lookup results based on the\n URL, or have them precompiled into a binary to avoid any\n lookup. Therefore, binary compatibility needs to be preserved\n on changes to types. (Use versioned type names to manage\n breaking changes.)\n\nNote: this functionality is not currently available in the official\nprotobuf release, and it is not used for type URLs beginning with\ntype.googleapis.com.\n\nSchemes other than `http`, `https` (or the empty scheme) might be\nused with implementation specific semantics." } }, "additionalProperties": {}, - "description": "`Any` contains an arbitrary serialized protocol buffer message along with a\nURL that describes the type of the serialized message.\n\nProtobuf library provides support to pack/unpack Any values in the form\nof utility functions or additional generated methods of the Any type.\n\nExample 1: Pack and unpack a message in C++.\n\n Foo foo = ...;\n Any any;\n any.PackFrom(foo);\n ...\n if (any.UnpackTo(\u0026foo)) {\n ...\n }\n\nExample 2: Pack and unpack a message in Java.\n\n Foo foo = ...;\n Any any = Any.pack(foo);\n ...\n if (any.is(Foo.class)) {\n foo = any.unpack(Foo.class);\n }\n // or ...\n if (any.isSameTypeAs(Foo.getDefaultInstance())) {\n foo = any.unpack(Foo.getDefaultInstance());\n }\n\n Example 3: Pack and unpack a message in Python.\n\n foo = Foo(...)\n any = Any()\n any.Pack(foo)\n ...\n if any.Is(Foo.DESCRIPTOR):\n any.Unpack(foo)\n ...\n\n Example 4: Pack and unpack a message in Go\n\n foo := \u0026pb.Foo{...}\n any, err := anypb.New(foo)\n if err != nil {\n ...\n }\n ...\n foo := \u0026pb.Foo{}\n if err := any.UnmarshalTo(foo); err != nil {\n ...\n }\n\nThe pack methods provided by protobuf library will by default use\n'type.googleapis.com/full.type.name' as the type URL and the unpack\nmethods only use the fully qualified type name after the last '/'\nin the type URL, for example \"foo.bar.com/x/y.z\" will yield type\nname \"y.z\".\n\nJSON\n====\nThe JSON representation of an `Any` value uses the regular\nrepresentation of the deserialized, embedded message, with an\nadditional field `@type` which contains the type URL. Example:\n\n package google.profile;\n message Person {\n string first_name = 1;\n string last_name = 2;\n }\n\n {\n \"@type\": \"type.googleapis.com/google.profile.Person\",\n \"firstName\": \u003cstring\u003e,\n \"lastName\": \u003cstring\u003e\n }\n\nIf the embedded message type is well-known and has a custom JSON\nrepresentation, that representation will be embedded adding a field\n`value` which holds the custom JSON in addition to the `@type`\nfield. Example (for message [google.protobuf.Duration][]):\n\n {\n \"@type\": \"type.googleapis.com/google.protobuf.Duration\",\n \"value\": \"1.212s\"\n }" + "description": "`Any` contains an arbitrary serialized protocol buffer message along with a\nURL that describes the type of the serialized message.\n\nProtobuf library provides support to pack/unpack Any values in the form\nof utility functions or additional generated methods of the Any type.\n\nExample 1: Pack and unpack a message in C++.\n\n Foo foo = ...;\n Any any;\n any.PackFrom(foo);\n ...\n if (any.UnpackTo(\u0026foo)) {\n ...\n }\n\nExample 2: Pack and unpack a message in Java.\n\n Foo foo = ...;\n Any any = Any.pack(foo);\n ...\n if (any.is(Foo.class)) {\n foo = any.unpack(Foo.class);\n }\n\n Example 3: Pack and unpack a message in Python.\n\n foo = Foo(...)\n any = Any()\n any.Pack(foo)\n ...\n if any.Is(Foo.DESCRIPTOR):\n any.Unpack(foo)\n ...\n\n Example 4: Pack and unpack a message in Go\n\n foo := \u0026pb.Foo{...}\n any, err := ptypes.MarshalAny(foo)\n ...\n foo := \u0026pb.Foo{}\n if err := ptypes.UnmarshalAny(any, foo); err != nil {\n ...\n }\n\nThe pack methods provided by protobuf library will by default use\n'type.googleapis.com/full.type.name' as the type URL and the unpack\nmethods only use the fully qualified type name after the last '/'\nin the type URL, for example \"foo.bar.com/x/y.z\" will yield type\nname \"y.z\".\n\n\nJSON\n====\nThe JSON representation of an `Any` value uses the regular\nrepresentation of the deserialized, embedded message, with an\nadditional field `@type` which contains the type URL. Example:\n\n package google.profile;\n message Person {\n string first_name = 1;\n string last_name = 2;\n }\n\n {\n \"@type\": \"type.googleapis.com/google.profile.Person\",\n \"firstName\": \u003cstring\u003e,\n \"lastName\": \u003cstring\u003e\n }\n\nIf the embedded message type is well-known and has a custom JSON\nrepresentation, that representation will be embedded adding a field\n`value` which holds the custom JSON in addition to the `@type`\nfield. Example (for message [google.protobuf.Duration][]):\n\n {\n \"@type\": \"type.googleapis.com/google.protobuf.Duration\",\n \"value\": \"1.212s\"\n }" }, "protobufNullValue": { "type": "string", @@ -650,7 +650,7 @@ "NULL_VALUE" ], "default": "NULL_VALUE", - "description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\nThe JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value." + "description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\n The JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value." }, "rpcStatus": { "type": "object", diff --git a/go/mtap/api/v1/events_grpc.pb.go b/go/mtap/api/v1/events_grpc.pb.go index 5862e571..05fafb00 100644 --- a/go/mtap/api/v1/events_grpc.pb.go +++ b/go/mtap/api/v1/events_grpc.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v5.26.1 +// - protoc v3.12.4 // source: mtap/api/v1/events.proto package v1 diff --git a/go/mtap/api/v1/pipeline.pb.go b/go/mtap/api/v1/pipeline.pb.go index 13e1a454..3d1567cf 100644 --- a/go/mtap/api/v1/pipeline.pb.go +++ b/go/mtap/api/v1/pipeline.pb.go @@ -2,18 +2,18 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v5.26.1 +// protoc-gen-go v1.31.0 +// protoc v3.12.4 // source: mtap/api/v1/pipeline.proto package v1 import ( + duration "github.com/golang/protobuf/ptypes/duration" + _struct "github.com/golang/protobuf/ptypes/struct" _ "google.golang.org/genproto/googleapis/api/annotations" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" - durationpb "google.golang.org/protobuf/types/known/durationpb" - structpb "google.golang.org/protobuf/types/known/structpb" reflect "reflect" sync "sync" ) @@ -34,9 +34,9 @@ type ProcessEventInPipelineRequest struct { // The name of the pipeline. PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"` // The serialized event to perform processing on. - Event *structpb.Struct `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` + Event *_struct.Struct `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` // The params to pass to the pipeline - Params *structpb.Struct `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` + Params *_struct.Struct `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` // * Whether the event should be kept alive after it is finished processing. Defaults to False. KeepAfter bool `protobuf:"varint,4,opt,name=keep_after,json=keepAfter,proto3" json:"keep_after,omitempty"` } @@ -80,14 +80,14 @@ func (x *ProcessEventInPipelineRequest) GetPipelineId() string { return "" } -func (x *ProcessEventInPipelineRequest) GetEvent() *structpb.Struct { +func (x *ProcessEventInPipelineRequest) GetEvent() *_struct.Struct { if x != nil { return x.Event } return nil } -func (x *ProcessEventInPipelineRequest) GetParams() *structpb.Struct { +func (x *ProcessEventInPipelineRequest) GetParams() *_struct.Struct { if x != nil { return x.Params } @@ -108,10 +108,10 @@ type ProcessEventInPipelineResponse struct { unknownFields protoimpl.UnknownFields // The serialized json event result of the pipeline processing - Event *structpb.Struct `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` + Event *_struct.Struct `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // Processor-specific timings of different operations. Includes a "process" // time for total time taken. - TimingInfo map[string]*durationpb.Duration `protobuf:"bytes,2,rep,name=timing_info,json=timingInfo,proto3" json:"timing_info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + TimingInfo map[string]*duration.Duration `protobuf:"bytes,2,rep,name=timing_info,json=timingInfo,proto3" json:"timing_info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` Result *ProcessEventInPipelineResponse_PipelineResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` } @@ -147,14 +147,14 @@ func (*ProcessEventInPipelineResponse) Descriptor() ([]byte, []int) { return file_mtap_api_v1_pipeline_proto_rawDescGZIP(), []int{1} } -func (x *ProcessEventInPipelineResponse) GetEvent() *structpb.Struct { +func (x *ProcessEventInPipelineResponse) GetEvent() *_struct.Struct { if x != nil { return x.Event } return nil } -func (x *ProcessEventInPipelineResponse) GetTimingInfo() map[string]*durationpb.Duration { +func (x *ProcessEventInPipelineResponse) GetTimingInfo() map[string]*duration.Duration { if x != nil { return x.TimingInfo } @@ -173,9 +173,9 @@ type ProcessEventInPipelineResponse_ComponentResult struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` - ResultDict *structpb.Struct `protobuf:"bytes,2,opt,name=result_dict,json=resultDict,proto3" json:"result_dict,omitempty"` - TimingInfo map[string]*durationpb.Duration `protobuf:"bytes,3,rep,name=timing_info,json=timingInfo,proto3" json:"timing_info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` + ResultDict *_struct.Struct `protobuf:"bytes,2,opt,name=result_dict,json=resultDict,proto3" json:"result_dict,omitempty"` + TimingInfo map[string]*duration.Duration `protobuf:"bytes,3,rep,name=timing_info,json=timingInfo,proto3" json:"timing_info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` } func (x *ProcessEventInPipelineResponse_ComponentResult) Reset() { @@ -217,14 +217,14 @@ func (x *ProcessEventInPipelineResponse_ComponentResult) GetIdentifier() string return "" } -func (x *ProcessEventInPipelineResponse_ComponentResult) GetResultDict() *structpb.Struct { +func (x *ProcessEventInPipelineResponse_ComponentResult) GetResultDict() *_struct.Struct { if x != nil { return x.ResultDict } return nil } -func (x *ProcessEventInPipelineResponse_ComponentResult) GetTimingInfo() map[string]*durationpb.Duration { +func (x *ProcessEventInPipelineResponse_ComponentResult) GetTimingInfo() map[string]*duration.Duration { if x != nil { return x.TimingInfo } @@ -237,7 +237,7 @@ type ProcessEventInPipelineResponse_PipelineResult struct { unknownFields protoimpl.UnknownFields ComponentResults []*ProcessEventInPipelineResponse_ComponentResult `protobuf:"bytes,1,rep,name=component_results,json=componentResults,proto3" json:"component_results,omitempty"` - ElapsedTime *durationpb.Duration `protobuf:"bytes,2,opt,name=elapsed_time,json=elapsedTime,proto3" json:"elapsed_time,omitempty"` + ElapsedTime *duration.Duration `protobuf:"bytes,2,opt,name=elapsed_time,json=elapsedTime,proto3" json:"elapsed_time,omitempty"` } func (x *ProcessEventInPipelineResponse_PipelineResult) Reset() { @@ -279,7 +279,7 @@ func (x *ProcessEventInPipelineResponse_PipelineResult) GetComponentResults() [] return nil } -func (x *ProcessEventInPipelineResponse_PipelineResult) GetElapsedTime() *durationpb.Duration { +func (x *ProcessEventInPipelineResponse_PipelineResult) GetElapsedTime() *duration.Duration { if x != nil { return x.ElapsedTime } @@ -396,10 +396,10 @@ var file_mtap_api_v1_pipeline_proto_goTypes = []interface{}{ (*ProcessEventInPipelineResponse)(nil), // 1: mtap.api.v1.ProcessEventInPipelineResponse (*ProcessEventInPipelineResponse_ComponentResult)(nil), // 2: mtap.api.v1.ProcessEventInPipelineResponse.ComponentResult (*ProcessEventInPipelineResponse_PipelineResult)(nil), // 3: mtap.api.v1.ProcessEventInPipelineResponse.PipelineResult - nil, // 4: mtap.api.v1.ProcessEventInPipelineResponse.TimingInfoEntry - nil, // 5: mtap.api.v1.ProcessEventInPipelineResponse.ComponentResult.TimingInfoEntry - (*structpb.Struct)(nil), // 6: google.protobuf.Struct - (*durationpb.Duration)(nil), // 7: google.protobuf.Duration + nil, // 4: mtap.api.v1.ProcessEventInPipelineResponse.TimingInfoEntry + nil, // 5: mtap.api.v1.ProcessEventInPipelineResponse.ComponentResult.TimingInfoEntry + (*_struct.Struct)(nil), // 6: google.protobuf.Struct + (*duration.Duration)(nil), // 7: google.protobuf.Duration } var file_mtap_api_v1_pipeline_proto_depIdxs = []int32{ 6, // 0: mtap.api.v1.ProcessEventInPipelineRequest.event:type_name -> google.protobuf.Struct diff --git a/go/mtap/api/v1/pipeline.swagger.json b/go/mtap/api/v1/pipeline.swagger.json index 42381acb..fa006ef0 100644 --- a/go/mtap/api/v1/pipeline.swagger.json +++ b/go/mtap/api/v1/pipeline.swagger.json @@ -119,7 +119,7 @@ "NULL_VALUE" ], "default": "NULL_VALUE", - "description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\nThe JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value." + "description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\n The JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value." }, "rpcStatus": { "type": "object", diff --git a/go/mtap/api/v1/pipeline_grpc.pb.go b/go/mtap/api/v1/pipeline_grpc.pb.go index 83835514..7af3df03 100644 --- a/go/mtap/api/v1/pipeline_grpc.pb.go +++ b/go/mtap/api/v1/pipeline_grpc.pb.go @@ -3,7 +3,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v5.26.1 +// - protoc v3.12.4 // source: mtap/api/v1/pipeline.proto package v1 diff --git a/go/mtap/api/v1/processing.pb.go b/go/mtap/api/v1/processing.pb.go index 3fcc94b4..4a041757 100644 --- a/go/mtap/api/v1/processing.pb.go +++ b/go/mtap/api/v1/processing.pb.go @@ -16,18 +16,18 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v5.26.1 +// protoc-gen-go v1.31.0 +// protoc v3.12.4 // source: mtap/api/v1/processing.proto package v1 import ( + duration "github.com/golang/protobuf/ptypes/duration" + _struct "github.com/golang/protobuf/ptypes/struct" _ "google.golang.org/genproto/googleapis/api/annotations" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" - durationpb "google.golang.org/protobuf/types/known/durationpb" - structpb "google.golang.org/protobuf/types/known/structpb" reflect "reflect" sync "sync" ) @@ -112,7 +112,7 @@ type ProcessRequest struct { // The event service instance uuid to use to get the event. EventServiceInstanceId string `protobuf:"bytes,4,opt,name=event_service_instance_id,json=eventServiceInstanceId,proto3" json:"event_service_instance_id,omitempty"` // A dynamic JSON object of runtime parameters that the processor will use. - Params *structpb.Struct `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` + Params *_struct.Struct `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` } func (x *ProcessRequest) Reset() { @@ -168,7 +168,7 @@ func (x *ProcessRequest) GetEventServiceInstanceId() string { return "" } -func (x *ProcessRequest) GetParams() *structpb.Struct { +func (x *ProcessRequest) GetParams() *_struct.Struct { if x != nil { return x.Params } @@ -183,9 +183,9 @@ type ProcessResponse struct { // Processor-specific timings of different operations. Includes a "process" // time for total time taken. - TimingInfo map[string]*durationpb.Duration `protobuf:"bytes,1,rep,name=timing_info,json=timingInfo,proto3" json:"timing_info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + TimingInfo map[string]*duration.Duration `protobuf:"bytes,1,rep,name=timing_info,json=timingInfo,proto3" json:"timing_info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` // The dynamic JSON object result returned by the processor. - Result *structpb.Struct `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` + Result *_struct.Struct `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // All label indices that were created on the event during processing. CreatedIndices []*CreatedIndex `protobuf:"bytes,3,rep,name=created_indices,json=createdIndices,proto3" json:"created_indices,omitempty"` } @@ -222,14 +222,14 @@ func (*ProcessResponse) Descriptor() ([]byte, []int) { return file_mtap_api_v1_processing_proto_rawDescGZIP(), []int{2} } -func (x *ProcessResponse) GetTimingInfo() map[string]*durationpb.Duration { +func (x *ProcessResponse) GetTimingInfo() map[string]*duration.Duration { if x != nil { return x.TimingInfo } return nil } -func (x *ProcessResponse) GetResult() *structpb.Struct { +func (x *ProcessResponse) GetResult() *_struct.Struct { if x != nil { return x.Result } @@ -302,7 +302,7 @@ type GetInfoResponse struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Metadata *structpb.Struct `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` + Metadata *_struct.Struct `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` } func (x *GetInfoResponse) Reset() { @@ -337,7 +337,7 @@ func (*GetInfoResponse) Descriptor() ([]byte, []int) { return file_mtap_api_v1_processing_proto_rawDescGZIP(), []int{4} } -func (x *GetInfoResponse) GetMetadata() *structpb.Struct { +func (x *GetInfoResponse) GetMetadata() *_struct.Struct { if x != nil { return x.Metadata } @@ -352,15 +352,15 @@ type TimerStats struct { unknownFields protoimpl.UnknownFields // The mean duration. - Mean *durationpb.Duration `protobuf:"bytes,1,opt,name=mean,proto3" json:"mean,omitempty"` + Mean *duration.Duration `protobuf:"bytes,1,opt,name=mean,proto3" json:"mean,omitempty"` // The standard deviation of the duration. - Std *durationpb.Duration `protobuf:"bytes,2,opt,name=std,proto3" json:"std,omitempty"` + Std *duration.Duration `protobuf:"bytes,2,opt,name=std,proto3" json:"std,omitempty"` // The maximum duration. - Max *durationpb.Duration `protobuf:"bytes,3,opt,name=max,proto3" json:"max,omitempty"` + Max *duration.Duration `protobuf:"bytes,3,opt,name=max,proto3" json:"max,omitempty"` // The minimum duration. - Min *durationpb.Duration `protobuf:"bytes,4,opt,name=min,proto3" json:"min,omitempty"` + Min *duration.Duration `protobuf:"bytes,4,opt,name=min,proto3" json:"min,omitempty"` // The sum of durations. - Sum *durationpb.Duration `protobuf:"bytes,5,opt,name=sum,proto3" json:"sum,omitempty"` + Sum *duration.Duration `protobuf:"bytes,5,opt,name=sum,proto3" json:"sum,omitempty"` } func (x *TimerStats) Reset() { @@ -395,35 +395,35 @@ func (*TimerStats) Descriptor() ([]byte, []int) { return file_mtap_api_v1_processing_proto_rawDescGZIP(), []int{5} } -func (x *TimerStats) GetMean() *durationpb.Duration { +func (x *TimerStats) GetMean() *duration.Duration { if x != nil { return x.Mean } return nil } -func (x *TimerStats) GetStd() *durationpb.Duration { +func (x *TimerStats) GetStd() *duration.Duration { if x != nil { return x.Std } return nil } -func (x *TimerStats) GetMax() *durationpb.Duration { +func (x *TimerStats) GetMax() *duration.Duration { if x != nil { return x.Max } return nil } -func (x *TimerStats) GetMin() *durationpb.Duration { +func (x *TimerStats) GetMin() *duration.Duration { if x != nil { return x.Min } return nil } -func (x *TimerStats) GetSum() *durationpb.Duration { +func (x *TimerStats) GetSum() *duration.Duration { if x != nil { return x.Sum } @@ -679,18 +679,18 @@ func file_mtap_api_v1_processing_proto_rawDescGZIP() []byte { var file_mtap_api_v1_processing_proto_msgTypes = make([]protoimpl.MessageInfo, 10) var file_mtap_api_v1_processing_proto_goTypes = []interface{}{ - (*CreatedIndex)(nil), // 0: mtap.api.v1.CreatedIndex - (*ProcessRequest)(nil), // 1: mtap.api.v1.ProcessRequest - (*ProcessResponse)(nil), // 2: mtap.api.v1.ProcessResponse - (*GetInfoRequest)(nil), // 3: mtap.api.v1.GetInfoRequest - (*GetInfoResponse)(nil), // 4: mtap.api.v1.GetInfoResponse - (*TimerStats)(nil), // 5: mtap.api.v1.TimerStats - (*GetStatsRequest)(nil), // 6: mtap.api.v1.GetStatsRequest - (*GetStatsResponse)(nil), // 7: mtap.api.v1.GetStatsResponse - nil, // 8: mtap.api.v1.ProcessResponse.TimingInfoEntry - nil, // 9: mtap.api.v1.GetStatsResponse.TimingStatsEntry - (*structpb.Struct)(nil), // 10: google.protobuf.Struct - (*durationpb.Duration)(nil), // 11: google.protobuf.Duration + (*CreatedIndex)(nil), // 0: mtap.api.v1.CreatedIndex + (*ProcessRequest)(nil), // 1: mtap.api.v1.ProcessRequest + (*ProcessResponse)(nil), // 2: mtap.api.v1.ProcessResponse + (*GetInfoRequest)(nil), // 3: mtap.api.v1.GetInfoRequest + (*GetInfoResponse)(nil), // 4: mtap.api.v1.GetInfoResponse + (*TimerStats)(nil), // 5: mtap.api.v1.TimerStats + (*GetStatsRequest)(nil), // 6: mtap.api.v1.GetStatsRequest + (*GetStatsResponse)(nil), // 7: mtap.api.v1.GetStatsResponse + nil, // 8: mtap.api.v1.ProcessResponse.TimingInfoEntry + nil, // 9: mtap.api.v1.GetStatsResponse.TimingStatsEntry + (*_struct.Struct)(nil), // 10: google.protobuf.Struct + (*duration.Duration)(nil), // 11: google.protobuf.Duration } var file_mtap_api_v1_processing_proto_depIdxs = []int32{ 10, // 0: mtap.api.v1.ProcessRequest.params:type_name -> google.protobuf.Struct diff --git a/go/mtap/api/v1/processing.swagger.json b/go/mtap/api/v1/processing.swagger.json index fdcbae8c..bf6fe19e 100644 --- a/go/mtap/api/v1/processing.swagger.json +++ b/go/mtap/api/v1/processing.swagger.json @@ -155,7 +155,7 @@ "NULL_VALUE" ], "default": "NULL_VALUE", - "description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\nThe JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value." + "description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\n The JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value." }, "rpcStatus": { "type": "object", diff --git a/go/mtap/api/v1/processing_grpc.pb.go b/go/mtap/api/v1/processing_grpc.pb.go index 94bd3882..9c279206 100644 --- a/go/mtap/api/v1/processing_grpc.pb.go +++ b/go/mtap/api/v1/processing_grpc.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v5.26.1 +// - protoc v3.12.4 // source: mtap/api/v1/processing.proto package v1