org.apache.beam.runners.fnexecution.environment

Interface EnvironmentFactory.Provider

All Known Implementing Classes:

DockerEnvironmentFactory.Provider, EmbeddedEnvironmentFactory.Provider, ExternalEnvironmentFactory.Provider, ProcessEnvironmentFactory.Provider, StaticRemoteEnvironmentFactory.Provider

Enclosing interface:

EnvironmentFactory

public static interface EnvironmentFactory.Provider

Provider for a EnvironmentFactory and ServerFactory for the environment.

Method Summary

Modifier and Type	Method and Description
EnvironmentFactory	createEnvironmentFactory(GrpcFnServer<FnApiControlClientPoolService> controlServiceServer, GrpcFnServer<GrpcLoggingService> loggingServiceServer, GrpcFnServer<LegacyArtifactRetrievalService> retrievalServiceServer, GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer, ControlClientPool clientPool, IdGenerator idGenerator) Creates EnvironmentFactory for the provided GrpcServices.
default ServerFactory	getServerFactory() Create the ServerFactory applicable to this environment.

Method Detail

createEnvironmentFactory

EnvironmentFactory createEnvironmentFactory(GrpcFnServer<FnApiControlClientPoolService> controlServiceServer,
                                            GrpcFnServer<GrpcLoggingService> loggingServiceServer,
                                            GrpcFnServer<LegacyArtifactRetrievalService> retrievalServiceServer,
                                            GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer,
                                            ControlClientPool clientPool,
                                            IdGenerator idGenerator)

Creates EnvironmentFactory for the provided GrpcServices.

getServerFactory

default ServerFactory getServerFactory()

Create the ServerFactory applicable to this environment.