1 /* 2 * Copyright 2022 Google LLC 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * https://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 package com.google.cloud.trace.v2; 18 19 import com.google.api.core.BetaApi; 20 import com.google.devtools.cloudtrace.v2.BatchWriteSpansRequest; 21 import com.google.devtools.cloudtrace.v2.Span; 22 import com.google.devtools.cloudtrace.v2.TraceServiceGrpc.TraceServiceImplBase; 23 import com.google.protobuf.AbstractMessage; 24 import com.google.protobuf.Empty; 25 import io.grpc.stub.StreamObserver; 26 import java.util.ArrayList; 27 import java.util.LinkedList; 28 import java.util.List; 29 import java.util.Queue; 30 import javax.annotation.Generated; 31 32 @BetaApi 33 @Generated("by gapic-generator-java") 34 public class MockTraceServiceImpl extends TraceServiceImplBase { 35 private List<AbstractMessage> requests; 36 private Queue<Object> responses; 37 MockTraceServiceImpl()38 public MockTraceServiceImpl() { 39 requests = new ArrayList<>(); 40 responses = new LinkedList<>(); 41 } 42 getRequests()43 public List<AbstractMessage> getRequests() { 44 return requests; 45 } 46 addResponse(AbstractMessage response)47 public void addResponse(AbstractMessage response) { 48 responses.add(response); 49 } 50 setResponses(List<AbstractMessage> responses)51 public void setResponses(List<AbstractMessage> responses) { 52 this.responses = new LinkedList<Object>(responses); 53 } 54 addException(Exception exception)55 public void addException(Exception exception) { 56 responses.add(exception); 57 } 58 reset()59 public void reset() { 60 requests = new ArrayList<>(); 61 responses = new LinkedList<>(); 62 } 63 64 @Override batchWriteSpans( BatchWriteSpansRequest request, StreamObserver<Empty> responseObserver)65 public void batchWriteSpans( 66 BatchWriteSpansRequest request, StreamObserver<Empty> responseObserver) { 67 Object response = responses.poll(); 68 if (response instanceof Empty) { 69 requests.add(request); 70 responseObserver.onNext(((Empty) response)); 71 responseObserver.onCompleted(); 72 } else if (response instanceof Exception) { 73 responseObserver.onError(((Exception) response)); 74 } else { 75 responseObserver.onError( 76 new IllegalArgumentException( 77 String.format( 78 "Unrecognized response type %s for method BatchWriteSpans, expected %s or %s", 79 response == null ? "null" : response.getClass().getName(), 80 Empty.class.getName(), 81 Exception.class.getName()))); 82 } 83 } 84 85 @Override createSpan(Span request, StreamObserver<Span> responseObserver)86 public void createSpan(Span request, StreamObserver<Span> responseObserver) { 87 Object response = responses.poll(); 88 if (response instanceof Span) { 89 requests.add(request); 90 responseObserver.onNext(((Span) response)); 91 responseObserver.onCompleted(); 92 } else if (response instanceof Exception) { 93 responseObserver.onError(((Exception) response)); 94 } else { 95 responseObserver.onError( 96 new IllegalArgumentException( 97 String.format( 98 "Unrecognized response type %s for method CreateSpan, expected %s or %s", 99 response == null ? "null" : response.getClass().getName(), 100 Span.class.getName(), 101 Exception.class.getName()))); 102 } 103 } 104 } 105