Skip to content
Snippets Groups Projects
Commit 432ade3b authored by Felix Reichenbach's avatar Felix Reichenbach
Browse files

OZG-7908 fix naming

parent 95914d9f
No related branches found
No related tags found
1 merge request!17Ozg 7908 aggregation manager server grpc interface
Showing with 62 additions and 62 deletions
......@@ -23,42 +23,42 @@
*/
syntax = "proto3";
package de.ozgcloud.aggregation.vorgangstub;
package de.ozgcloud.aggregation.data;
option java_multiple_files = true;
option java_package = "de.ozgcloud.aggregation.vorgangstub";
option java_outer_classname = "VorgangStubModelProto";
option java_package = "de.ozgcloud.aggregation.data";
option java_outer_classname = "AggregationDataModelProto";
message SubmitVorgangStubRequest {
message GrpcSendAggregationDataRequest {
string name = 1;
string mandant = 2;
repeated VorgangStub vorgangStubs = 3;
repeated GrpcAggregationData aggregationData = 3;
}
message VorgangStub {
message GrpcAggregationData {
string id = 1;
string status = 2;
string eingangDatum = 3;
string vorgangName = 4;
Payload payload = 5;
GrpcPayload payload = 5;
}
message Payload {
repeated Property properties = 1;
message GrpcPayload {
repeated GrpcProperty properties = 1;
}
message Property {
message GrpcProperty {
string key = 1;
oneof value {
string stringValue = 2;
Payload nestedPayload = 3;
ValueList valueList = 4;
GrpcPayload nestedPayload = 3;
GrpcValueList valueList = 4;
}
}
message ValueList {
message GrpcValueList {
repeated string values = 1;
}
message SubmitVorgangStubResponse {}
\ No newline at end of file
message GrpcSendAggregationDataResponse {}
\ No newline at end of file
......@@ -23,14 +23,14 @@
*/
syntax = "proto3";
package de.ozgcloud.aggregation.vorgangstub;
package de.ozgcloud.aggregation.data;
import "vorgangstub.model.proto";
import "aggregationdata.model.proto";
option java_multiple_files = true;
option java_package = "de.ozgcloud.aggregation.vorgangstub";
option java_outer_classname = "VorgangStubProto";
option java_package = "de.ozgcloud.aggregation.data";
option java_outer_classname = "AggregationDataProto";
service VorgangStubService {
rpc SubmitVorgangStubs(stream SubmitVorgangStubRequest) returns (SubmitVorgangStubResponse);
service AggregationDataService {
rpc SendAggregationData(stream GrpcSendAggregationDataRequest) returns (GrpcSendAggregationDataResponse);
}
\ No newline at end of file
......@@ -23,27 +23,27 @@
*/
syntax = "proto3";
package de.ozgcloud.aggregation.configuration;
package de.ozgcloud.aggregation.mapping;
option java_multiple_files = true;
option java_package = "de.ozgcloud.aggregation.configuration";
option java_outer_classname = "ConfigurationModelProto";
option java_package = "de.ozgcloud.aggregation.mapping";
option java_outer_classname = "MappingModelProto";
message GetAggregationConfigurationsRequest {}
message GrpcGetAggregationMappingsRequest {}
message GetAggregationConfigurationsResponse {
repeated AggregationConfiguration configurations = 1;
message GrpcGetAggregationMappingsResponse {
repeated GrpcAggregationMapping mappings = 1;
}
message AggregationConfiguration {
message GrpcAggregationMapping {
string name = 1;
string formEngineName = 2;
string formId = 3;
repeated AggregationMapping mappings = 4;
repeated GrpcFieldMapping fieldMappings = 4;
}
message AggregationMapping {
message GrpcFieldMapping {
string source = 1;
string target = 2;
......
......@@ -23,14 +23,14 @@
*/
syntax = "proto3";
package de.ozgcloud.aggregation.configuration;
package de.ozgcloud.aggregation.mapping;
import "configuration.model.proto";
import "mapping.model.proto";
option java_multiple_files = true;
option java_package = "de.ozgcloud.aggregation.configuration";
option java_outer_classname = "AggregationConfigurationProto";
option java_package = "de.ozgcloud.aggregation.mapping";
option java_outer_classname = "AggregationMappingProto";
service AggregationConfigurationService {
rpc GetAggregationConfigurations(GetAggregationConfigurationsRequest) returns (GetAggregationConfigurationsResponse);
service AggregationMappingService {
rpc GetAggregationMappings(GrpcGetAggregationMappingsRequest) returns (GrpcGetAggregationMappingsResponse);
}
\ No newline at end of file
package de.ozgcloud.aggregation.configuration;
import de.ozgcloud.aggregation.configuration.AggregationConfigurationServiceGrpc.AggregationConfigurationServiceImplBase;
import io.grpc.stub.StreamObserver;
class AggregationConfigurationGrpcService extends AggregationConfigurationServiceImplBase {
@Override
public void getAggregationConfigurations(GetAggregationConfigurationsRequest request,
StreamObserver<GetAggregationConfigurationsResponse> responseObserver) {
// Implement in OZG-????
}
}
package de.ozgcloud.aggregation.data;
import de.ozgcloud.aggregation.data.AggregationDataServiceGrpc.AggregationDataServiceImplBase;
import io.grpc.stub.StreamObserver;
class AggregationDataGrpcService extends AggregationDataServiceImplBase {
@Override
public StreamObserver<GrpcSendAggregationDataRequest> sendAggregationData(StreamObserver<GrpcSendAggregationDataResponse> responseObserver) {
// Implement in OZG-7909
return null;
}
}
package de.ozgcloud.aggregation.mapping;
import de.ozgcloud.aggregation.mapping.AggregationMappingServiceGrpc.AggregationMappingServiceImplBase;
import io.grpc.stub.StreamObserver;
class AggregationMappingGrpcService extends AggregationMappingServiceImplBase {
@Override
public void getAggregationMappings(GrpcGetAggregationMappingsRequest request,
StreamObserver<GrpcGetAggregationMappingsResponse> responseObserver) {
// Implement in OZG-????
}
}
package de.ozgcloud.aggregation.vorgangstub;
import de.ozgcloud.aggregation.vorgangstub.VorgangStubServiceGrpc.VorgangStubServiceImplBase;
import io.grpc.stub.StreamObserver;
class VorgangGrpcService extends VorgangStubServiceImplBase {
@Override
public StreamObserver<SubmitVorgangStubRequest> submitVorgangStubs(StreamObserver<SubmitVorgangStubResponse> responseObserver) {
// Implement in OZG-7909
return null;
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment