diff --git a/README.md b/README.md index 4045bfd6..9e60aebc 100644 --- a/README.md +++ b/README.md @@ -39,7 +39,7 @@ make run-client-gateway MESSAGE="hello" go run example/client/gateway/main.go -message "hello" # Or using grpcurl -grpcurl -plaintext -d '{"message": "hello"}' localhost:8081 uber.devexp.submitqueue.gateway.SubmitQueueGateway/Ping +grpcurl -plaintext -d '{"message": "hello"}' localhost:8081 uber.submitqueue.gateway.SubmitQueueGateway/Ping ``` For detailed instructions, see [example/README.md](example/README.md). @@ -336,7 +336,7 @@ make proto 3. **Or use grpcurl:** ```bash grpcurl -plaintext -d '{"message": "hello"}' \ - localhost:8081 uber.devexp.submitqueue.gateway.SubmitQueueGateway/Ping + localhost:8081 uber.submitqueue.gateway.SubmitQueueGateway/Ping ``` #### Testing All Services diff --git a/example/README.md b/example/README.md index 87fd7d04..3929f5fe 100644 --- a/example/README.md +++ b/example/README.md @@ -91,23 +91,23 @@ go install github.com/fullstorydev/grpcurl/cmd/grpcurl@latest ```bash # Ping -grpcurl -plaintext -d '{"message": "hello"}' localhost:8081 uber.devexp.submitqueue.gateway.SubmitQueueGateway/Ping -grpcurl -plaintext -d '{"message": "hello"}' localhost:8082 uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator/Ping +grpcurl -plaintext -d '{"message": "hello"}' localhost:8081 uber.submitqueue.gateway.SubmitQueueGateway/Ping +grpcurl -plaintext -d '{"message": "hello"}' localhost:8082 uber.submitqueue.orchestrator.SubmitQueueOrchestrator/Ping # List services grpcurl -plaintext localhost:8081 list grpcurl -plaintext localhost:8082 list # Describe a service -grpcurl -plaintext localhost:8081 describe uber.devexp.submitqueue.gateway.SubmitQueueGateway -grpcurl -plaintext localhost:8082 describe uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator +grpcurl -plaintext localhost:8081 describe uber.submitqueue.gateway.SubmitQueueGateway +grpcurl -plaintext localhost:8082 describe uber.submitqueue.orchestrator.SubmitQueueOrchestrator ``` ## API Reference ### Gateway Service -**Service**: `uber.devexp.submitqueue.gateway.SubmitQueueGateway` +**Service**: `uber.submitqueue.gateway.SubmitQueueGateway` **Proto**: `gateway/proto/gateway.proto` | Method | Description | @@ -117,7 +117,7 @@ grpcurl -plaintext localhost:8082 describe uber.devexp.submitqueue.orchestrator. ### Orchestrator Service -**Service**: `uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator` +**Service**: `uber.submitqueue.orchestrator.SubmitQueueOrchestrator` **Proto**: `orchestrator/proto/orchestrator.proto` | Method | Description | diff --git a/gateway/proto/gateway.proto b/gateway/proto/gateway.proto index e1495193..7bfc223e 100644 --- a/gateway/proto/gateway.proto +++ b/gateway/proto/gateway.proto @@ -1,11 +1,11 @@ syntax = "proto3"; -package uber.devexp.submitqueue.gateway; +package uber.submitqueue.gateway; option go_package = "github.com/uber/submitqueue/gateway/protopb"; option java_multiple_files = true; option java_outer_classname = "GatewayProto"; -option java_package = "com.uber.devexp.submitqueue.gateway"; +option java_package = "com.uber.submitqueue.gateway"; // *************** // API domain definitions. diff --git a/gateway/protopb/gateway.pb.go b/gateway/protopb/gateway.pb.go index cfc144d5..0b35ad43 100644 --- a/gateway/protopb/gateway.pb.go +++ b/gateway/protopb/gateway.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v3.21.12 +// protoc-gen-go v1.36.10 +// protoc v5.29.3 // source: gateway.proto package protopb @@ -262,7 +262,7 @@ type LandRequest struct { // Change (such as a pull request) to land into the target branch. Target branch is defined by the queue configuration. Change *Change `protobuf:"bytes,2,opt,name=change,proto3" json:"change,omitempty"` // Source control integration strategy to use for this land operation. If not specified, the default queue strategy is used. - Strategy Strategy `protobuf:"varint,4,opt,name=strategy,proto3,enum=uber.devexp.submitqueue.gateway.Strategy" json:"strategy,omitempty"` + Strategy Strategy `protobuf:"varint,4,opt,name=strategy,proto3,enum=uber.submitqueue.gateway.Strategy" json:"strategy,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -469,7 +469,7 @@ var File_gateway_proto protoreflect.FileDescriptor const file_gateway_proto_rawDesc = "" + "\n" + - "\rgateway.proto\x12\x1fuber.devexp.submitqueue.gateway\"'\n" + + "\rgateway.proto\x12\x18uber.submitqueue.gateway\"'\n" + "\vPingRequest\x12\x18\n" + "\amessage\x18\x01 \x01(\tR\amessage\"\x85\x01\n" + "\fPingResponse\x12\x18\n" + @@ -478,28 +478,28 @@ const file_gateway_proto_rawDesc = "" + "\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x1a\n" + "\bhostname\x18\x04 \x01(\tR\bhostname\"\x1c\n" + "\x06Change\x12\x12\n" + - "\x04uris\x18\x01 \x03(\tR\x04uris\"\xab\x01\n" + + "\x04uris\x18\x01 \x03(\tR\x04uris\"\x9d\x01\n" + "\vLandRequest\x12\x14\n" + - "\x05queue\x18\x01 \x01(\tR\x05queue\x12?\n" + - "\x06change\x18\x02 \x01(\v2'.uber.devexp.submitqueue.gateway.ChangeR\x06change\x12E\n" + - "\bstrategy\x18\x04 \x01(\x0e2).uber.devexp.submitqueue.gateway.StrategyR\bstrategy\"\"\n" + + "\x05queue\x18\x01 \x01(\tR\x05queue\x128\n" + + "\x06change\x18\x02 \x01(\v2 .uber.submitqueue.gateway.ChangeR\x06change\x12>\n" + + "\bstrategy\x18\x04 \x01(\x0e2\".uber.submitqueue.gateway.StrategyR\bstrategy\"\"\n" + "\fLandResponse\x12\x12\n" + "\x04sqid\x18\x01 \x01(\tR\x04sqid\"!\n" + "\x05Error\x12\x18\n" + - "\amessage\x18\x01 \x01(\tR\amessage\"l\n" + - "\x16UnrecognizedQueueError\x12<\n" + - "\x05error\x18\x01 \x01(\v2&.uber.devexp.submitqueue.gateway.ErrorR\x05error\x12\x14\n" + + "\amessage\x18\x01 \x01(\tR\amessage\"e\n" + + "\x16UnrecognizedQueueError\x125\n" + + "\x05error\x18\x01 \x01(\v2\x1f.uber.submitqueue.gateway.ErrorR\x05error\x12\x14\n" + "\x05queue\x18\x02 \x01(\tR\x05queue*A\n" + "\bStrategy\x12\v\n" + "\aDEFAULT\x10\x00\x12\n" + "\n" + "\x06REBASE\x10\x01\x12\x11\n" + "\rSQUASH_REBASE\x10\x02\x12\t\n" + - "\x05MERGE\x10\x032\xe2\x01\n" + - "\x12SubmitQueueGateway\x12e\n" + - "\x04Ping\x12,.uber.devexp.submitqueue.gateway.PingRequest\x1a-.uber.devexp.submitqueue.gateway.PingResponse\"\x00\x12e\n" + - "\x04Land\x12,.uber.devexp.submitqueue.gateway.LandRequest\x1a-.uber.devexp.submitqueue.gateway.LandResponse\"\x00Bb\n" + - "#com.uber.devexp.submitqueue.gatewayB\fGatewayProtoP\x01Z+github.com/uber/submitqueue/gateway/protopbb\x06proto3" + "\x05MERGE\x10\x032\xc6\x01\n" + + "\x12SubmitQueueGateway\x12W\n" + + "\x04Ping\x12%.uber.submitqueue.gateway.PingRequest\x1a&.uber.submitqueue.gateway.PingResponse\"\x00\x12W\n" + + "\x04Land\x12%.uber.submitqueue.gateway.LandRequest\x1a&.uber.submitqueue.gateway.LandResponse\"\x00B[\n" + + "\x1ccom.uber.submitqueue.gatewayB\fGatewayProtoP\x01Z+github.com/uber/submitqueue/gateway/protopbb\x06proto3" var ( file_gateway_proto_rawDescOnce sync.Once @@ -516,23 +516,23 @@ func file_gateway_proto_rawDescGZIP() []byte { var file_gateway_proto_enumTypes = make([]protoimpl.EnumInfo, 1) var file_gateway_proto_msgTypes = make([]protoimpl.MessageInfo, 7) var file_gateway_proto_goTypes = []any{ - (Strategy)(0), // 0: uber.devexp.submitqueue.gateway.Strategy - (*PingRequest)(nil), // 1: uber.devexp.submitqueue.gateway.PingRequest - (*PingResponse)(nil), // 2: uber.devexp.submitqueue.gateway.PingResponse - (*Change)(nil), // 3: uber.devexp.submitqueue.gateway.Change - (*LandRequest)(nil), // 4: uber.devexp.submitqueue.gateway.LandRequest - (*LandResponse)(nil), // 5: uber.devexp.submitqueue.gateway.LandResponse - (*Error)(nil), // 6: uber.devexp.submitqueue.gateway.Error - (*UnrecognizedQueueError)(nil), // 7: uber.devexp.submitqueue.gateway.UnrecognizedQueueError + (Strategy)(0), // 0: uber.submitqueue.gateway.Strategy + (*PingRequest)(nil), // 1: uber.submitqueue.gateway.PingRequest + (*PingResponse)(nil), // 2: uber.submitqueue.gateway.PingResponse + (*Change)(nil), // 3: uber.submitqueue.gateway.Change + (*LandRequest)(nil), // 4: uber.submitqueue.gateway.LandRequest + (*LandResponse)(nil), // 5: uber.submitqueue.gateway.LandResponse + (*Error)(nil), // 6: uber.submitqueue.gateway.Error + (*UnrecognizedQueueError)(nil), // 7: uber.submitqueue.gateway.UnrecognizedQueueError } var file_gateway_proto_depIdxs = []int32{ - 3, // 0: uber.devexp.submitqueue.gateway.LandRequest.change:type_name -> uber.devexp.submitqueue.gateway.Change - 0, // 1: uber.devexp.submitqueue.gateway.LandRequest.strategy:type_name -> uber.devexp.submitqueue.gateway.Strategy - 6, // 2: uber.devexp.submitqueue.gateway.UnrecognizedQueueError.error:type_name -> uber.devexp.submitqueue.gateway.Error - 1, // 3: uber.devexp.submitqueue.gateway.SubmitQueueGateway.Ping:input_type -> uber.devexp.submitqueue.gateway.PingRequest - 4, // 4: uber.devexp.submitqueue.gateway.SubmitQueueGateway.Land:input_type -> uber.devexp.submitqueue.gateway.LandRequest - 2, // 5: uber.devexp.submitqueue.gateway.SubmitQueueGateway.Ping:output_type -> uber.devexp.submitqueue.gateway.PingResponse - 5, // 6: uber.devexp.submitqueue.gateway.SubmitQueueGateway.Land:output_type -> uber.devexp.submitqueue.gateway.LandResponse + 3, // 0: uber.submitqueue.gateway.LandRequest.change:type_name -> uber.submitqueue.gateway.Change + 0, // 1: uber.submitqueue.gateway.LandRequest.strategy:type_name -> uber.submitqueue.gateway.Strategy + 6, // 2: uber.submitqueue.gateway.UnrecognizedQueueError.error:type_name -> uber.submitqueue.gateway.Error + 1, // 3: uber.submitqueue.gateway.SubmitQueueGateway.Ping:input_type -> uber.submitqueue.gateway.PingRequest + 4, // 4: uber.submitqueue.gateway.SubmitQueueGateway.Land:input_type -> uber.submitqueue.gateway.LandRequest + 2, // 5: uber.submitqueue.gateway.SubmitQueueGateway.Ping:output_type -> uber.submitqueue.gateway.PingResponse + 5, // 6: uber.submitqueue.gateway.SubmitQueueGateway.Land:output_type -> uber.submitqueue.gateway.LandResponse 5, // [5:7] is the sub-list for method output_type 3, // [3:5] is the sub-list for method input_type 3, // [3:3] is the sub-list for extension type_name diff --git a/gateway/protopb/gateway.pb.yarpc.go b/gateway/protopb/gateway.pb.yarpc.go index 17760cd6..c3ba2343 100644 --- a/gateway/protopb/gateway.pb.yarpc.go +++ b/gateway/protopb/gateway.pb.yarpc.go @@ -29,7 +29,7 @@ type SubmitQueueGatewayYARPCClient interface { func newSubmitQueueGatewayYARPCClient(clientConfig transport.ClientConfig, anyResolver jsonpb.AnyResolver, options ...protobuf.ClientOption) SubmitQueueGatewayYARPCClient { return &_SubmitQueueGatewayYARPCCaller{protobuf.NewStreamClient( protobuf.ClientParams{ - ServiceName: "uber.devexp.submitqueue.gateway.SubmitQueueGateway", + ServiceName: "uber.submitqueue.gateway.SubmitQueueGateway", ClientConfig: clientConfig, AnyResolver: anyResolver, Options: options, @@ -57,7 +57,7 @@ func buildSubmitQueueGatewayYARPCProcedures(params buildSubmitQueueGatewayYARPCP handler := &_SubmitQueueGatewayYARPCHandler{params.Server} return protobuf.BuildProcedures( protobuf.BuildProceduresParams{ - ServiceName: "uber.devexp.submitqueue.gateway.SubmitQueueGateway", + ServiceName: "uber.submitqueue.gateway.SubmitQueueGateway", UnaryHandlerParams: []protobuf.BuildProceduresUnaryHandlerParams{ { MethodName: "Ping", @@ -189,7 +189,7 @@ func NewFxSubmitQueueGatewayYARPCProcedures() interface{} { // // See https://github.com/grpc/grpc/blob/master/doc/server-reflection.md. var SubmitQueueGatewayReflectionMeta = reflection.ServerMeta{ - ServiceName: "uber.devexp.submitqueue.gateway.SubmitQueueGateway", + ServiceName: "uber.submitqueue.gateway.SubmitQueueGateway", FileDescriptors: yarpcFileDescriptorClosuref1a937782ebbded5, } @@ -283,36 +283,36 @@ var ( var yarpcFileDescriptorClosuref1a937782ebbded5 = [][]byte{ // gateway.proto []byte{ - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x93, 0x5d, 0x6f, 0xd3, 0x3e, - 0x14, 0xc6, 0x9b, 0xbe, 0xad, 0x3d, 0xe9, 0xfe, 0xea, 0xdf, 0x42, 0x28, 0x9a, 0x26, 0xd1, 0x19, - 0x89, 0x95, 0xb7, 0x54, 0x2a, 0xb7, 0x48, 0xa8, 0x85, 0x30, 0x2e, 0x06, 0xea, 0x1c, 0x7a, 0xc3, - 0xcd, 0xe4, 0xa4, 0x47, 0x69, 0x24, 0xf2, 0x52, 0xdb, 0x19, 0x8c, 0x7b, 0x3e, 0x0d, 0xdf, 0x8a, - 0x4f, 0x82, 0xe2, 0xb8, 0x5b, 0x6e, 0x20, 0xbd, 0x3b, 0x76, 0xce, 0x2f, 0xcf, 0x73, 0x1e, 0xdb, - 0x70, 0x1c, 0x71, 0x85, 0xdf, 0xf8, 0xad, 0x9b, 0x8b, 0x4c, 0x65, 0xe4, 0x51, 0x11, 0xa0, 0x70, - 0x37, 0x78, 0x83, 0xdf, 0x73, 0x57, 0x16, 0x41, 0x12, 0xab, 0x5d, 0x81, 0x05, 0xba, 0xa6, 0x8d, - 0x9e, 0x83, 0xbd, 0x8a, 0xd3, 0x88, 0xe1, 0xae, 0x40, 0xa9, 0x88, 0x03, 0x47, 0x09, 0x4a, 0xc9, - 0x23, 0x74, 0xac, 0x89, 0x35, 0x1d, 0xb2, 0xfd, 0x92, 0xfe, 0xb4, 0x60, 0x54, 0x75, 0xca, 0x3c, - 0x4b, 0x25, 0xfe, 0xbd, 0x95, 0x9c, 0xc1, 0x48, 0xa2, 0xb8, 0x89, 0x43, 0xbc, 0x4e, 0x79, 0x82, - 0x4e, 0x5b, 0x7f, 0xb6, 0xcd, 0xde, 0x27, 0x9e, 0x20, 0x39, 0x85, 0xa1, 0x8a, 0x13, 0x94, 0x8a, - 0x27, 0xb9, 0xd3, 0x99, 0x58, 0xd3, 0x0e, 0xbb, 0xdf, 0x20, 0x27, 0x30, 0xd8, 0x66, 0x52, 0x69, - 0xb8, 0xab, 0xe1, 0xbb, 0x35, 0x3d, 0x85, 0xfe, 0xdb, 0x2d, 0x4f, 0x23, 0x24, 0x04, 0xba, 0x85, - 0x88, 0xa5, 0x63, 0x4d, 0x3a, 0xd3, 0x21, 0xd3, 0x35, 0xfd, 0x65, 0x81, 0x7d, 0xc9, 0xd3, 0xcd, - 0x7e, 0x9e, 0x07, 0xd0, 0xd3, 0xf3, 0x1a, 0x8b, 0xd5, 0x82, 0xbc, 0x81, 0x7e, 0xa8, 0xff, 0xa1, - 0xad, 0xd9, 0xf3, 0x73, 0xb7, 0x21, 0x26, 0xb7, 0x92, 0x64, 0x06, 0x23, 0x1e, 0x0c, 0xa4, 0x12, - 0x5c, 0x61, 0x74, 0xab, 0x0d, 0xfe, 0x37, 0x7f, 0xda, 0xf8, 0x0b, 0xdf, 0x00, 0xec, 0x0e, 0xa5, - 0x14, 0x46, 0x95, 0x59, 0x13, 0x29, 0x81, 0xae, 0xdc, 0xc5, 0x1b, 0x63, 0x56, 0xd7, 0xf4, 0x0c, - 0x7a, 0x9e, 0x10, 0x99, 0xf8, 0xc7, 0xd1, 0x7c, 0x85, 0x87, 0xeb, 0x54, 0x60, 0x98, 0x45, 0x69, - 0xfc, 0x03, 0x37, 0x57, 0xa5, 0x6c, 0xc5, 0xbc, 0x86, 0x1e, 0x96, 0x85, 0x26, 0xec, 0xf9, 0x93, - 0x46, 0x93, 0x1a, 0x63, 0x15, 0x74, 0x1f, 0x5e, 0xbb, 0x16, 0xde, 0xb3, 0x05, 0x0c, 0xf6, 0xa3, - 0x10, 0x1b, 0x8e, 0xde, 0x79, 0xef, 0x17, 0xeb, 0xcb, 0xcf, 0xe3, 0x16, 0x01, 0xe8, 0x33, 0x6f, - 0xb9, 0xf0, 0xbd, 0xb1, 0x45, 0xfe, 0x87, 0x63, 0xff, 0x6a, 0xbd, 0xf0, 0x3f, 0x5c, 0x9b, 0xad, - 0x36, 0x19, 0x42, 0xef, 0xa3, 0xc7, 0x2e, 0xbc, 0x71, 0x67, 0xfe, 0xdb, 0x02, 0xe2, 0x6b, 0x75, - 0xed, 0xf5, 0xa2, 0x12, 0x27, 0x08, 0xdd, 0xf2, 0x86, 0x91, 0x17, 0x8d, 0x36, 0x6b, 0x57, 0xf6, - 0xe4, 0xe5, 0x81, 0xdd, 0x55, 0xc6, 0xb4, 0x55, 0xca, 0x94, 0xa9, 0x1f, 0x20, 0x53, 0xbb, 0x49, - 0x07, 0xc8, 0xd4, 0x8f, 0x92, 0xb6, 0x96, 0x01, 0x3c, 0x0e, 0xb3, 0xa4, 0x89, 0x5a, 0x8e, 0xcc, - 0xf4, 0xab, 0xf2, 0xbd, 0xae, 0xac, 0x2f, 0xcf, 0xa3, 0x58, 0x6d, 0x8b, 0xc0, 0x0d, 0xb3, 0x64, - 0x56, 0xb2, 0xb3, 0x1a, 0x34, 0x33, 0xd0, 0x4c, 0x3f, 0xee, 0x3c, 0x08, 0xfa, 0xba, 0x78, 0xf5, - 0x27, 0x00, 0x00, 0xff, 0xff, 0xe8, 0x4d, 0xf1, 0x97, 0xf6, 0x03, 0x00, 0x00, + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x53, 0x4d, 0x8f, 0xd3, 0x30, + 0x10, 0x5d, 0xf7, 0x6b, 0xdb, 0x49, 0x17, 0x15, 0x0b, 0xa1, 0x68, 0x55, 0x89, 0xae, 0x25, 0xa0, + 0x02, 0x29, 0x95, 0x8a, 0x90, 0x38, 0x21, 0xb5, 0x10, 0x96, 0xc3, 0x82, 0xba, 0x0e, 0x15, 0x12, + 0x1c, 0x56, 0x4e, 0x3a, 0x4a, 0x73, 0x48, 0xd2, 0xda, 0x0e, 0x68, 0xb9, 0xf3, 0x33, 0xf8, 0x3b, + 0xfc, 0x2e, 0x14, 0xc7, 0xdd, 0xcd, 0x25, 0xe5, 0x36, 0x1e, 0xbf, 0x37, 0xf3, 0xe6, 0x79, 0x0c, + 0x67, 0xb1, 0xd0, 0xf8, 0x53, 0xdc, 0x7a, 0x3b, 0x99, 0xeb, 0x9c, 0xba, 0x45, 0x88, 0xd2, 0x53, + 0x45, 0x98, 0x26, 0x7a, 0x5f, 0x60, 0x81, 0x9e, 0xbd, 0x67, 0xcf, 0xc1, 0x59, 0x25, 0x59, 0xcc, + 0x71, 0x5f, 0xa0, 0xd2, 0xd4, 0x85, 0xd3, 0x14, 0x95, 0x12, 0x31, 0xba, 0x64, 0x42, 0xa6, 0x03, + 0x7e, 0x38, 0xb2, 0xdf, 0x04, 0x86, 0x15, 0x52, 0xed, 0xf2, 0x4c, 0x61, 0x33, 0x94, 0x5e, 0xc0, + 0x50, 0xa1, 0xfc, 0x91, 0x44, 0x78, 0x93, 0x89, 0x14, 0xdd, 0x96, 0xb9, 0x76, 0x6c, 0xee, 0xb3, + 0x48, 0x91, 0x8e, 0x61, 0xa0, 0x93, 0x14, 0x95, 0x16, 0xe9, 0xce, 0x6d, 0x4f, 0xc8, 0xb4, 0xcd, + 0xef, 0x13, 0xf4, 0x1c, 0xfa, 0xdb, 0x5c, 0x69, 0x43, 0xee, 0x18, 0xf2, 0xdd, 0x99, 0x8d, 0xa1, + 0xf7, 0x6e, 0x2b, 0xb2, 0x18, 0x29, 0x85, 0x4e, 0x21, 0x13, 0xe5, 0x92, 0x49, 0x7b, 0x3a, 0xe0, + 0x26, 0x66, 0x7f, 0x08, 0x38, 0x57, 0x22, 0xdb, 0x1c, 0xe6, 0x79, 0x04, 0x5d, 0x33, 0xaf, 0x95, + 0x58, 0x1d, 0xe8, 0x1b, 0xe8, 0x45, 0xa6, 0x86, 0x91, 0xe6, 0xcc, 0x27, 0x5e, 0x93, 0x3f, 0x5e, + 0xd5, 0x8b, 0x5b, 0x3c, 0x7d, 0x0b, 0x7d, 0xa5, 0xa5, 0xd0, 0x18, 0xdf, 0x1a, 0x65, 0x0f, 0xe6, + 0xac, 0x99, 0x1b, 0x58, 0x24, 0xbf, 0xe3, 0x30, 0x06, 0xc3, 0x4a, 0x9e, 0x35, 0x91, 0x42, 0x47, + 0xed, 0x93, 0x8d, 0x95, 0x67, 0x62, 0x76, 0x01, 0x5d, 0x5f, 0xca, 0x5c, 0x1e, 0x79, 0x0c, 0x84, + 0xc7, 0xeb, 0x4c, 0x62, 0x94, 0xc7, 0x59, 0xf2, 0x0b, 0x37, 0xd7, 0x65, 0xdb, 0x8a, 0xf3, 0x1a, + 0xba, 0x58, 0x06, 0x86, 0xe1, 0xcc, 0x9f, 0x34, 0xab, 0x33, 0x78, 0x5e, 0xa1, 0xef, 0x7d, 0x6a, + 0xd5, 0x7c, 0x7a, 0xb1, 0x80, 0xfe, 0x61, 0x06, 0xea, 0xc0, 0xe9, 0x7b, 0xff, 0xc3, 0x62, 0x7d, + 0xf5, 0x65, 0x74, 0x42, 0x01, 0x7a, 0xdc, 0x5f, 0x2e, 0x02, 0x7f, 0x44, 0xe8, 0x43, 0x38, 0x0b, + 0xae, 0xd7, 0x8b, 0xe0, 0xe3, 0x8d, 0x4d, 0xb5, 0xe8, 0x00, 0xba, 0x9f, 0x7c, 0x7e, 0xe9, 0x8f, + 0xda, 0xf3, 0xbf, 0x04, 0x68, 0x60, 0xba, 0x1b, 0x91, 0x97, 0x55, 0x73, 0xfa, 0x15, 0x3a, 0xe5, + 0x32, 0xd1, 0xa7, 0xcd, 0xfa, 0x6a, 0x6b, 0x79, 0xfe, 0xec, 0x7f, 0xb0, 0xca, 0x4e, 0x76, 0x52, + 0x16, 0x2e, 0x0d, 0x3e, 0x56, 0xb8, 0xb6, 0x1f, 0xc7, 0x0a, 0xd7, 0xdf, 0x89, 0x9d, 0x2c, 0xbf, + 0xc3, 0x38, 0xca, 0xd3, 0x46, 0xf8, 0x72, 0x68, 0x47, 0x5b, 0x95, 0x1f, 0x6e, 0x45, 0xbe, 0xbd, + 0x8c, 0x13, 0xbd, 0x2d, 0x42, 0x2f, 0xca, 0xd3, 0x59, 0x49, 0x9a, 0xd5, 0x48, 0x33, 0x4b, 0x9a, + 0x99, 0xdf, 0xb9, 0x0b, 0xc3, 0x9e, 0x09, 0x5e, 0xfd, 0x0b, 0x00, 0x00, 0xff, 0xff, 0x8e, 0x7d, + 0xf5, 0x79, 0xb7, 0x03, 0x00, 0x00, }, } diff --git a/gateway/protopb/gateway_grpc.pb.go b/gateway/protopb/gateway_grpc.pb.go index 04820f4d..46128f3f 100644 --- a/gateway/protopb/gateway_grpc.pb.go +++ b/gateway/protopb/gateway_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.6.1 -// - protoc v3.21.12 +// - protoc-gen-go-grpc v1.5.1 +// - protoc v5.29.3 // source: gateway.proto package protopb @@ -19,8 +19,8 @@ import ( const _ = grpc.SupportPackageIsVersion9 const ( - SubmitQueueGateway_Ping_FullMethodName = "/uber.devexp.submitqueue.gateway.SubmitQueueGateway/Ping" - SubmitQueueGateway_Land_FullMethodName = "/uber.devexp.submitqueue.gateway.SubmitQueueGateway/Land" + SubmitQueueGateway_Ping_FullMethodName = "/uber.submitqueue.gateway.SubmitQueueGateway/Ping" + SubmitQueueGateway_Land_FullMethodName = "/uber.submitqueue.gateway.SubmitQueueGateway/Land" ) // SubmitQueueGatewayClient is the client API for SubmitQueueGateway service. @@ -86,10 +86,10 @@ type SubmitQueueGatewayServer interface { type UnimplementedSubmitQueueGatewayServer struct{} func (UnimplementedSubmitQueueGatewayServer) Ping(context.Context, *PingRequest) (*PingResponse, error) { - return nil, status.Error(codes.Unimplemented, "method Ping not implemented") + return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented") } func (UnimplementedSubmitQueueGatewayServer) Land(context.Context, *LandRequest) (*LandResponse, error) { - return nil, status.Error(codes.Unimplemented, "method Land not implemented") + return nil, status.Errorf(codes.Unimplemented, "method Land not implemented") } func (UnimplementedSubmitQueueGatewayServer) mustEmbedUnimplementedSubmitQueueGatewayServer() {} func (UnimplementedSubmitQueueGatewayServer) testEmbeddedByValue() {} @@ -102,7 +102,7 @@ type UnsafeSubmitQueueGatewayServer interface { } func RegisterSubmitQueueGatewayServer(s grpc.ServiceRegistrar, srv SubmitQueueGatewayServer) { - // If the following call panics, it indicates UnimplementedSubmitQueueGatewayServer was + // If the following call pancis, it indicates UnimplementedSubmitQueueGatewayServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. @@ -152,7 +152,7 @@ func _SubmitQueueGateway_Land_Handler(srv interface{}, ctx context.Context, dec // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var SubmitQueueGateway_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "uber.devexp.submitqueue.gateway.SubmitQueueGateway", + ServiceName: "uber.submitqueue.gateway.SubmitQueueGateway", HandlerType: (*SubmitQueueGatewayServer)(nil), Methods: []grpc.MethodDesc{ { diff --git a/orchestrator/proto/orchestrator.proto b/orchestrator/proto/orchestrator.proto index a0e9bfa5..74a8e0fc 100644 --- a/orchestrator/proto/orchestrator.proto +++ b/orchestrator/proto/orchestrator.proto @@ -1,11 +1,11 @@ syntax = "proto3"; -package uber.devexp.submitqueue.orchestrator; +package uber.submitqueue.orchestrator; option go_package = "github.com/uber/submitqueue/orchestrator/protopb"; option java_multiple_files = true; option java_outer_classname = "OrchestratorProto"; -option java_package = "com.uber.devexp.submitqueue.orchestrator"; +option java_package = "com.uber.submitqueue.orchestrator"; // PingRequest is the request for the Ping method message PingRequest { diff --git a/orchestrator/protopb/orchestrator.pb.go b/orchestrator/protopb/orchestrator.pb.go index 35e0b0e9..70914dfa 100644 --- a/orchestrator/protopb/orchestrator.pb.go +++ b/orchestrator/protopb/orchestrator.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v3.21.12 +// protoc-gen-go v1.36.10 +// protoc v5.29.3 // source: orchestrator.proto package protopb @@ -144,17 +144,17 @@ var File_orchestrator_proto protoreflect.FileDescriptor const file_orchestrator_proto_rawDesc = "" + "\n" + - "\x12orchestrator.proto\x12$uber.devexp.submitqueue.orchestrator\"'\n" + + "\x12orchestrator.proto\x12\x1duber.submitqueue.orchestrator\"'\n" + "\vPingRequest\x12\x18\n" + "\amessage\x18\x01 \x01(\tR\amessage\"\x85\x01\n" + "\fPingResponse\x12\x18\n" + "\amessage\x18\x01 \x01(\tR\amessage\x12!\n" + "\fservice_name\x18\x02 \x01(\tR\vserviceName\x12\x1c\n" + "\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x1a\n" + - "\bhostname\x18\x04 \x01(\tR\bhostname2\x8a\x01\n" + - "\x17SubmitQueueOrchestrator\x12o\n" + - "\x04Ping\x121.uber.devexp.submitqueue.orchestrator.PingRequest\x1a2.uber.devexp.submitqueue.orchestrator.PingResponse\"\x00Bq\n" + - "(com.uber.devexp.submitqueue.orchestratorB\x11OrchestratorProtoP\x01Z0github.com/uber/submitqueue/orchestrator/protopbb\x06proto3" + "\bhostname\x18\x04 \x01(\tR\bhostname2|\n" + + "\x17SubmitQueueOrchestrator\x12a\n" + + "\x04Ping\x12*.uber.submitqueue.orchestrator.PingRequest\x1a+.uber.submitqueue.orchestrator.PingResponse\"\x00Bj\n" + + "!com.uber.submitqueue.orchestratorB\x11OrchestratorProtoP\x01Z0github.com/uber/submitqueue/orchestrator/protopbb\x06proto3" var ( file_orchestrator_proto_rawDescOnce sync.Once @@ -170,12 +170,12 @@ func file_orchestrator_proto_rawDescGZIP() []byte { var file_orchestrator_proto_msgTypes = make([]protoimpl.MessageInfo, 2) var file_orchestrator_proto_goTypes = []any{ - (*PingRequest)(nil), // 0: uber.devexp.submitqueue.orchestrator.PingRequest - (*PingResponse)(nil), // 1: uber.devexp.submitqueue.orchestrator.PingResponse + (*PingRequest)(nil), // 0: uber.submitqueue.orchestrator.PingRequest + (*PingResponse)(nil), // 1: uber.submitqueue.orchestrator.PingResponse } var file_orchestrator_proto_depIdxs = []int32{ - 0, // 0: uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator.Ping:input_type -> uber.devexp.submitqueue.orchestrator.PingRequest - 1, // 1: uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator.Ping:output_type -> uber.devexp.submitqueue.orchestrator.PingResponse + 0, // 0: uber.submitqueue.orchestrator.SubmitQueueOrchestrator.Ping:input_type -> uber.submitqueue.orchestrator.PingRequest + 1, // 1: uber.submitqueue.orchestrator.SubmitQueueOrchestrator.Ping:output_type -> uber.submitqueue.orchestrator.PingResponse 1, // [1:2] is the sub-list for method output_type 0, // [0:1] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name diff --git a/orchestrator/protopb/orchestrator.pb.yarpc.go b/orchestrator/protopb/orchestrator.pb.yarpc.go index 41ba19d5..703c8dfd 100644 --- a/orchestrator/protopb/orchestrator.pb.yarpc.go +++ b/orchestrator/protopb/orchestrator.pb.yarpc.go @@ -28,7 +28,7 @@ type SubmitQueueOrchestratorYARPCClient interface { func newSubmitQueueOrchestratorYARPCClient(clientConfig transport.ClientConfig, anyResolver jsonpb.AnyResolver, options ...protobuf.ClientOption) SubmitQueueOrchestratorYARPCClient { return &_SubmitQueueOrchestratorYARPCCaller{protobuf.NewStreamClient( protobuf.ClientParams{ - ServiceName: "uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator", + ServiceName: "uber.submitqueue.orchestrator.SubmitQueueOrchestrator", ClientConfig: clientConfig, AnyResolver: anyResolver, Options: options, @@ -55,7 +55,7 @@ func buildSubmitQueueOrchestratorYARPCProcedures(params buildSubmitQueueOrchestr handler := &_SubmitQueueOrchestratorYARPCHandler{params.Server} return protobuf.BuildProcedures( protobuf.BuildProceduresParams{ - ServiceName: "uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator", + ServiceName: "uber.submitqueue.orchestrator.SubmitQueueOrchestrator", UnaryHandlerParams: []protobuf.BuildProceduresUnaryHandlerParams{ { MethodName: "Ping", @@ -177,7 +177,7 @@ func NewFxSubmitQueueOrchestratorYARPCProcedures() interface{} { // // See https://github.com/grpc/grpc/blob/master/doc/server-reflection.md. var SubmitQueueOrchestratorReflectionMeta = reflection.ServerMeta{ - ServiceName: "uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator", + ServiceName: "uber.submitqueue.orchestrator.SubmitQueueOrchestrator", FileDescriptors: yarpcFileDescriptorClosure96b6e6782baaa298, } @@ -233,23 +233,23 @@ var ( var yarpcFileDescriptorClosure96b6e6782baaa298 = [][]byte{ // orchestrator.proto []byte{ - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x91, 0xbf, 0x4e, 0xc3, 0x30, - 0x10, 0x87, 0x31, 0xad, 0x80, 0x5e, 0xbb, 0xe0, 0x85, 0xa8, 0x62, 0x28, 0x11, 0x12, 0x99, 0x1c, - 0x28, 0x6f, 0xd0, 0x07, 0x80, 0x10, 0x36, 0x16, 0x94, 0x84, 0x53, 0xe2, 0xc1, 0xb1, 0xe3, 0xb3, - 0x2b, 0x5e, 0x80, 0x85, 0xa7, 0x46, 0x71, 0xf9, 0xe3, 0x05, 0xa9, 0xdd, 0x7c, 0xe7, 0xdf, 0x67, - 0xdd, 0xe7, 0x03, 0xae, 0x6d, 0xd3, 0x21, 0x39, 0x5b, 0x39, 0x6d, 0x85, 0xb1, 0xda, 0x69, 0x7e, - 0xed, 0x6b, 0xb4, 0xe2, 0x0d, 0xb7, 0xf8, 0x6e, 0x04, 0xf9, 0x5a, 0x49, 0x37, 0x78, 0xf4, 0x28, - 0xe2, 0x6c, 0x7a, 0x03, 0xf3, 0x42, 0xf6, 0x6d, 0x89, 0x83, 0x47, 0x72, 0x3c, 0x81, 0x53, 0x85, - 0x44, 0x55, 0x8b, 0x09, 0x5b, 0xb1, 0x6c, 0x56, 0xfe, 0x94, 0xe9, 0x07, 0x83, 0xc5, 0x2e, 0x49, - 0x46, 0xf7, 0x84, 0xff, 0x47, 0xf9, 0x15, 0x2c, 0x08, 0xed, 0x56, 0x36, 0xf8, 0xda, 0x57, 0x0a, - 0x93, 0xe3, 0x70, 0x3d, 0xff, 0xee, 0x3d, 0x54, 0x0a, 0xf9, 0x25, 0xcc, 0x9c, 0x54, 0x48, 0xae, - 0x52, 0x26, 0x99, 0xac, 0x58, 0x36, 0x29, 0xff, 0x1a, 0x7c, 0x09, 0x67, 0x9d, 0x26, 0x17, 0xe0, - 0x69, 0x80, 0x7f, 0xeb, 0xf5, 0x27, 0x83, 0x8b, 0xe7, 0x60, 0xf3, 0x34, 0xda, 0x3c, 0x46, 0x32, - 0x5c, 0xc3, 0x74, 0x1c, 0x91, 0xdf, 0x89, 0x7d, 0xdc, 0x45, 0x24, 0xbe, 0x5c, 0x1f, 0x82, 0xec, - 0x7e, 0x20, 0x3d, 0xda, 0x0c, 0x90, 0x35, 0x5a, 0xed, 0x85, 0x6e, 0xce, 0xe3, 0x51, 0x8b, 0x71, - 0x45, 0x05, 0x7b, 0xb9, 0x6d, 0xa5, 0xeb, 0x7c, 0x2d, 0x1a, 0xad, 0xf2, 0xf1, 0x95, 0x3c, 0xc2, - 0xf3, 0x18, 0xcf, 0xc3, 0x52, 0x4d, 0x5d, 0x9f, 0x84, 0xc3, 0xfd, 0x57, 0x00, 0x00, 0x00, 0xff, - 0xff, 0x72, 0x59, 0xe2, 0x9d, 0xf3, 0x01, 0x00, 0x00, + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x91, 0xbf, 0x4e, 0xc3, 0x30, + 0x10, 0xc6, 0x31, 0xad, 0x80, 0x5e, 0xbb, 0xe0, 0x85, 0xa8, 0x02, 0xa9, 0xcd, 0x42, 0x05, 0x92, + 0x83, 0xe0, 0x0d, 0xfa, 0x00, 0x10, 0xc2, 0xc6, 0x82, 0xec, 0xe8, 0x94, 0x18, 0xc9, 0x71, 0xea, + 0xb3, 0x99, 0x58, 0x79, 0x6f, 0x14, 0x97, 0x3f, 0x5e, 0x88, 0xd8, 0x7c, 0xe7, 0xef, 0x27, 0xdd, + 0x4f, 0x1f, 0x70, 0xeb, 0xea, 0x16, 0xc9, 0x3b, 0xe9, 0xad, 0x13, 0xbd, 0xb3, 0xde, 0xf2, 0x8b, + 0xa0, 0xd0, 0x09, 0x0a, 0xca, 0x68, 0xbf, 0x0b, 0x18, 0x50, 0xa4, 0xa1, 0xfc, 0x12, 0xe6, 0xa5, + 0xee, 0x9a, 0x0a, 0x77, 0x01, 0xc9, 0xf3, 0x0c, 0x8e, 0x0d, 0x12, 0xc9, 0x06, 0x33, 0xb6, 0x62, + 0x9b, 0x59, 0xf5, 0x3d, 0xe6, 0x1f, 0x0c, 0x16, 0xfb, 0x24, 0xf5, 0xb6, 0x23, 0xfc, 0x3b, 0xca, + 0xd7, 0xb0, 0x20, 0x74, 0x6f, 0xba, 0xc6, 0x97, 0x4e, 0x1a, 0xcc, 0x0e, 0xe3, 0xf7, 0xfc, 0x6b, + 0x77, 0x2f, 0x0d, 0xf2, 0x73, 0x98, 0x79, 0x6d, 0x90, 0xbc, 0x34, 0x7d, 0x36, 0x59, 0xb1, 0xcd, + 0xa4, 0xfa, 0x5d, 0xf0, 0x25, 0x9c, 0xb4, 0x96, 0x7c, 0x84, 0xa7, 0x11, 0xfe, 0x99, 0x6f, 0xdf, + 0xe1, 0xec, 0x29, 0xca, 0x3c, 0x0e, 0x32, 0x0f, 0x89, 0x0b, 0x97, 0x30, 0x1d, 0x2e, 0xe4, 0x57, + 0x62, 0xd4, 0x59, 0x24, 0xc2, 0xcb, 0xeb, 0x7f, 0x65, 0xf7, 0xca, 0xf9, 0xc1, 0xf6, 0x15, 0xd6, + 0xb5, 0x35, 0xe3, 0xcc, 0xf6, 0x34, 0xbd, 0xaa, 0x1c, 0x5a, 0x28, 0xd9, 0xf3, 0x4d, 0xa3, 0x7d, + 0x1b, 0x94, 0xa8, 0xad, 0x29, 0x06, 0xbc, 0x48, 0xf0, 0x22, 0xc5, 0x8b, 0xd8, 0x5b, 0xaf, 0xd4, + 0x51, 0x7c, 0xdc, 0x7d, 0x06, 0x00, 0x00, 0xff, 0xff, 0x86, 0x7a, 0x29, 0x9c, 0xd6, 0x01, 0x00, + 0x00, }, } diff --git a/orchestrator/protopb/orchestrator_grpc.pb.go b/orchestrator/protopb/orchestrator_grpc.pb.go index 9597e2cf..22d8ea92 100644 --- a/orchestrator/protopb/orchestrator_grpc.pb.go +++ b/orchestrator/protopb/orchestrator_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.6.1 -// - protoc v3.21.12 +// - protoc-gen-go-grpc v1.5.1 +// - protoc v5.29.3 // source: orchestrator.proto package protopb @@ -19,7 +19,7 @@ import ( const _ = grpc.SupportPackageIsVersion9 const ( - SubmitQueueOrchestrator_Ping_FullMethodName = "/uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator/Ping" + SubmitQueueOrchestrator_Ping_FullMethodName = "/uber.submitqueue.orchestrator.SubmitQueueOrchestrator/Ping" ) // SubmitQueueOrchestratorClient is the client API for SubmitQueueOrchestrator service. @@ -69,7 +69,7 @@ type SubmitQueueOrchestratorServer interface { type UnimplementedSubmitQueueOrchestratorServer struct{} func (UnimplementedSubmitQueueOrchestratorServer) Ping(context.Context, *PingRequest) (*PingResponse, error) { - return nil, status.Error(codes.Unimplemented, "method Ping not implemented") + return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented") } func (UnimplementedSubmitQueueOrchestratorServer) mustEmbedUnimplementedSubmitQueueOrchestratorServer() { } @@ -83,7 +83,7 @@ type UnsafeSubmitQueueOrchestratorServer interface { } func RegisterSubmitQueueOrchestratorServer(s grpc.ServiceRegistrar, srv SubmitQueueOrchestratorServer) { - // If the following call panics, it indicates UnimplementedSubmitQueueOrchestratorServer was + // If the following call pancis, it indicates UnimplementedSubmitQueueOrchestratorServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. @@ -115,7 +115,7 @@ func _SubmitQueueOrchestrator_Ping_Handler(srv interface{}, ctx context.Context, // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var SubmitQueueOrchestrator_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "uber.devexp.submitqueue.orchestrator.SubmitQueueOrchestrator", + ServiceName: "uber.submitqueue.orchestrator.SubmitQueueOrchestrator", HandlerType: (*SubmitQueueOrchestratorServer)(nil), Methods: []grpc.MethodDesc{ {