Class InProcessGRPCServer

java.lang.Object

io.temporal.internal.testservice.InProcessGRPCServer

public class InProcessGRPCServer
extends Object

Generates an in-process service and the channel for it. Useful for testing, usually with mock and spy services.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	InProcessGRPCServer.MessageSizeChecker	This interceptor is needed for testing RESOURCE_EXHAUSTED error handling because in-process gRPC server doesn't check and cannot be configured to check message size.

Constructor Summary

Constructors

Constructor	Description
InProcessGRPCServer(Collection<io.grpc.BindableService> services)	Register the passed services in a new in-memory gRPC service with health service providing SERVING status for all of them.
InProcessGRPCServer(Collection<io.grpc.BindableService> services, boolean createChannel)	Register the passed services in a new in-memory gRPC service with health service providing SERVING status for all of them.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
io.grpc.ManagedChannel	getChannel()
io.grpc.Server	getServer()
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
void	shutdownNow()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InProcessGRPCServer

public InProcessGRPCServer(Collection<io.grpc.BindableService> services)

Register the passed services in a new in-memory gRPC service with health service providing SERVING status for all of them. Also provides a channel to access the created server, see getChannel()

Parameters:

services - implementations of the gRPC services. For example, one of them can be an instance extending WorkflowServiceGrpc.WorkflowServiceImplBase

InProcessGRPCServer

public InProcessGRPCServer(Collection<io.grpc.BindableService> services,
 boolean createChannel)

Register the passed services in a new in-memory gRPC service with health service providing SERVING status for all of them.

Parameters:

services - implementations of the gRPC services. For example, one of them can be an instance extending WorkflowServiceGrpc.WorkflowServiceImplBase

createChannel - defines if a channel to access the created server should be created. If true, the created channel will be accessible using getChannel()

Method Details

shutdown

public void shutdown()

shutdownNow

public void shutdownNow()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

awaitTermination

public boolean awaitTermination(long timeout,
 TimeUnit unit)

getServer

public io.grpc.Server getServer()

getChannel

@Nullable
public io.grpc.ManagedChannel getChannel()