org.apache.beam.runners.fnexecution.control

Class SdkHarnessClientControlService

java.lang.Object

org.apache.beam.runners.fnexecution.control.SdkHarnessClientControlService

All Implemented Interfaces:

io.grpc.BindableService, java.lang.AutoCloseable, FnService

public class SdkHarnessClientControlService
extends java.lang.Object
implements FnService

A service providing SdkHarnessClient based on an internally managed FnApiControlClientPoolService.

Method Summary

Modifier and Type	Method and Description
io.grpc.ServerServiceDefinition	bindService()
void	close() .
static SdkHarnessClientControlService	create(java.util.function.Supplier<FnDataService> dataService)
SdkHarnessClient	getClient()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static SdkHarnessClientControlService create(java.util.function.Supplier<FnDataService> dataService)

getClient

public SdkHarnessClient getClient()

close

public void close()
           throws java.lang.Exception

Description copied from interface: FnService

.

There should be no more calls to any service method by the time a call to FnService.close() begins. Specifically, this means that a Server that this service is bound to should have completed a call to the Server.shutdown() method, and all future incoming calls will be rejected.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface FnService

Throws:

java.lang.Exception

bindService

public io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService