2681

Committed 20 Nov 2024 10:22PM CUT coverage: 74.857%. First build

Build # 2681

Build Type

Pull #963

buildkite

Committed by

taylanisikdemir

Commit Message

Update codecov config with new github org

Pull Request Pull Request #963: Update codecov config with new github org

Run Details

14511 of 19385 relevant lines covered (74.86%)

0.75 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/com/uber/cadence/internal/compatibility/proto/serviceclient/IGrpcServiceStubs.java

/*
 *  Modifications Copyright (c) 2017-2021 Uber Technologies Inc.
 *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
 *  use this file except in compliance with the License. A copy of the License is
 *  located at
 *
 *  http://aws.amazon.com/apache2.0
 *
 *  or in the "license" file accompanying this file. This file is distributed on
 *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 *  express or implied. See the License for the specific language governing
 *  permissions and limitations under the License.
 */
package com.uber.cadence.internal.compatibility.proto.serviceclient;

import com.uber.cadence.api.v1.DomainAPIGrpc;
import com.uber.cadence.api.v1.MetaAPIGrpc.MetaAPIBlockingStub;
import com.uber.cadence.api.v1.MetaAPIGrpc.MetaAPIFutureStub;
import com.uber.cadence.api.v1.VisibilityAPIGrpc;
import com.uber.cadence.api.v1.WorkerAPIGrpc;
import com.uber.cadence.api.v1.WorkflowAPIGrpc;
import com.uber.cadence.serviceclient.ClientOptions;
import java.util.concurrent.TimeUnit;

public interface IGrpcServiceStubs {

  int DEFAULT_LOCAL_CADENCE_SERVER_GRPC_PORT = 7833;

  /** Returns gRPC stubs with default options domain service. */
  static IGrpcServiceStubs newInstance() {
    return new GrpcServiceStubs(
        ClientOptions.newBuilder().setPort(DEFAULT_LOCAL_CADENCE_SERVER_GRPC_PORT).build());
  }

  /** Returns gRPC stubs with given options domain service. */
  static IGrpcServiceStubs newInstance(ClientOptions options) {
    return new GrpcServiceStubs(options);
  }

  ClientOptions getOptions();

  /** @return Blocking (synchronous) stub to domain service. */
  DomainAPIGrpc.DomainAPIBlockingStub domainBlockingStub();

  /** @return Future (asynchronous) stub to domain service. */
  DomainAPIGrpc.DomainAPIFutureStub domainFutureStub();

  /** @return Blocking (synchronous) stub to visibility service. */
  VisibilityAPIGrpc.VisibilityAPIBlockingStub visibilityBlockingStub();

  /** @return Future (asynchronous) stub to visibility service. */
  VisibilityAPIGrpc.VisibilityAPIFutureStub visibilityFutureStub();

  /** @return Blocking (synchronous) stub to worker service. */
  WorkerAPIGrpc.WorkerAPIBlockingStub workerBlockingStub();

  /** @return Future (asynchronous) stub to worker service. */
  WorkerAPIGrpc.WorkerAPIFutureStub workerFutureStub();

  /** @return Blocking (synchronous) stub to workflow service. */
  WorkflowAPIGrpc.WorkflowAPIBlockingStub workflowBlockingStub();

  /** @return Future (asynchronous) stub to workflow service. */
  WorkflowAPIGrpc.WorkflowAPIFutureStub workflowFutureStub();

  /** @return Blocking (synchronous) stub to meta service. */
  MetaAPIFutureStub metaFutureStub();

  /** @return Future (asynchronous) stub to meta service. */
  MetaAPIBlockingStub metaBlockingStub();

  void shutdown();

  void shutdownNow();

  boolean isShutdown();

  boolean isTerminated();

  boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException;
}

1	/*
2	* Modifications Copyright (c) 2017-2021 Uber Technologies Inc.
3	* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
4	*
5	* Licensed under the Apache License, Version 2.0 (the "License"). You may not
6	* use this file except in compliance with the License. A copy of the License is
7	* located at
8	*
9	* http://aws.amazon.com/apache2.0
10	*
11	* or in the "license" file accompanying this file. This file is distributed on
12	* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
13	* express or implied. See the License for the specific language governing
14	* permissions and limitations under the License.
15	*/
16	package com.uber.cadence.internal.compatibility.proto.serviceclient;
17
18	import com.uber.cadence.api.v1.DomainAPIGrpc;
19	import com.uber.cadence.api.v1.MetaAPIGrpc.MetaAPIBlockingStub;
20	import com.uber.cadence.api.v1.MetaAPIGrpc.MetaAPIFutureStub;
21	import com.uber.cadence.api.v1.VisibilityAPIGrpc;
22	import com.uber.cadence.api.v1.WorkerAPIGrpc;
23	import com.uber.cadence.api.v1.WorkflowAPIGrpc;
24	import com.uber.cadence.serviceclient.ClientOptions;
25	import java.util.concurrent.TimeUnit;
26
27	public interface IGrpcServiceStubs {
28
29	int DEFAULT_LOCAL_CADENCE_SERVER_GRPC_PORT = 7833;
30
31	/** Returns gRPC stubs with default options domain service. */
32	static IGrpcServiceStubs newInstance() {
33	return new GrpcServiceStubs(	×
34	ClientOptions.newBuilder().setPort(DEFAULT_LOCAL_CADENCE_SERVER_GRPC_PORT).build());	×
35	}
36
37	/** Returns gRPC stubs with given options domain service. */
38	static IGrpcServiceStubs newInstance(ClientOptions options) {
39	return new GrpcServiceStubs(options);	×
40	}
41
42	ClientOptions getOptions();
43
44	/** @return Blocking (synchronous) stub to domain service. */
45	DomainAPIGrpc.DomainAPIBlockingStub domainBlockingStub();
46
47	/** @return Future (asynchronous) stub to domain service. */
48	DomainAPIGrpc.DomainAPIFutureStub domainFutureStub();
49
50	/** @return Blocking (synchronous) stub to visibility service. */
51	VisibilityAPIGrpc.VisibilityAPIBlockingStub visibilityBlockingStub();
52
53	/** @return Future (asynchronous) stub to visibility service. */
54	VisibilityAPIGrpc.VisibilityAPIFutureStub visibilityFutureStub();
55
56	/** @return Blocking (synchronous) stub to worker service. */
57	WorkerAPIGrpc.WorkerAPIBlockingStub workerBlockingStub();
58
59	/** @return Future (asynchronous) stub to worker service. */
60	WorkerAPIGrpc.WorkerAPIFutureStub workerFutureStub();
61
62	/** @return Blocking (synchronous) stub to workflow service. */
63	WorkflowAPIGrpc.WorkflowAPIBlockingStub workflowBlockingStub();
64
65	/** @return Future (asynchronous) stub to workflow service. */
66	WorkflowAPIGrpc.WorkflowAPIFutureStub workflowFutureStub();
67
68	/** @return Blocking (synchronous) stub to meta service. */
69	MetaAPIFutureStub metaFutureStub();
70
71	/** @return Future (asynchronous) stub to meta service. */
72	MetaAPIBlockingStub metaBlockingStub();
73
74	void shutdown();
75
76	void shutdownNow();
77
78	boolean isShutdown();
79
80	boolean isTerminated();
81
82	boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException;
83	}

uber / cadence-java-client / 2681

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous