org.apache.beam.runners.fnexecution

Class GrpcFnServer<ServiceT extends FnService>

java.lang.Object

org.apache.beam.runners.fnexecution.GrpcFnServer<ServiceT>

All Implemented Interfaces:

java.lang.AutoCloseable

public class GrpcFnServer<ServiceT extends FnService>
extends java.lang.Object
implements java.lang.AutoCloseable

A gRPC Server which manages a single FnService. The lifetime of the service is bound to the GrpcFnServer.

Method Summary

Modifier and Type	Method and Description
static <ServiceT extends FnService> GrpcFnServer<ServiceT>	allocatePortAndCreateFor(ServiceT service, ServerFactory factory) Create a GrpcFnServer for the provided FnService running on an arbitrary port.
void	close()
static <ServiceT extends FnService> GrpcFnServer<ServiceT>	create(ServiceT service, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor endpoint, ServerFactory factory) Create a GrpcFnServer for the provided FnService which will run at the endpoint specified in the Endpoints.ApiServiceDescriptor.
org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor	getApiServiceDescriptor() Get an Endpoints.ApiServiceDescriptor describing the endpoint this GrpcFnServer is bound to.
io.grpc.Server	getServer() Get the underlying Server contained by this GrpcFnServer.
ServiceT	getService() Get the service exposed by this GrpcFnServer.

Methods inherited from class java.lang.Object

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

Method Detail

allocatePortAndCreateFor

public static <ServiceT extends FnService> GrpcFnServer<ServiceT> allocatePortAndCreateFor(ServiceT service,
                                                                                           ServerFactory factory)
                                                                                    throws java.io.IOException

Create a GrpcFnServer for the provided FnService running on an arbitrary port.

Throws:

java.io.IOException

create

public static <ServiceT extends FnService> GrpcFnServer<ServiceT> create(ServiceT service,
                                                                         org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor endpoint,
                                                                         ServerFactory factory)
                                                                  throws java.io.IOException

Create a GrpcFnServer for the provided FnService which will run at the endpoint specified in the Endpoints.ApiServiceDescriptor.

Throws:

java.io.IOException

getApiServiceDescriptor

public org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor getApiServiceDescriptor()

Get an Endpoints.ApiServiceDescriptor describing the endpoint this GrpcFnServer is bound to.

getService

public ServiceT getService()

Get the service exposed by this GrpcFnServer.

getServer

public io.grpc.Server getServer()

Get the underlying Server contained by this GrpcFnServer.

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception