Package com.google.apphosting.runtime

Class ApiProxyImpl

java.lang.Object

com.google.apphosting.runtime.ApiProxyImpl

All Implemented Interfaces:

com.google.apphosting.api.ApiProxy.Delegate<ApiProxyImpl.EnvironmentImpl>

public class ApiProxyImpl
extends Object
implements com.google.apphosting.api.ApiProxy.Delegate<ApiProxyImpl.EnvironmentImpl>

ApiProxyImpl is a concrete implementation of the ApiProxy.Delegate interface.

It receives user-supplied API calls, translates them into the APIRequest arguments that APIHost expects, calls the asynchronous APIHost service, and translates any return value or error condition back into something that the user would expect.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ApiProxyImpl.Builder	Builder for ApiProxyImpl.Config.
static class	ApiProxyImpl.CurrentRequestThread	A thread created by {@code ThreadManager.currentRequestThreadFactory().
static final class	ApiProxyImpl.EnvironmentImpl	To implement ApiProxy.Environment, we use a class that wraps around an UPRequest and retrieves the necessary information from it.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BACKEND_ID_KEY
static final String	CLOUD_SQL_JDBC_CONNECTIVITY_ENABLED_KEY
static final String	INSTANCE_ID_KEY

Method Summary

Modifier and Type	Method	Description
static ApiProxyImpl.Builder	builder()
ApiProxyImpl.EnvironmentImpl	createEnvironment(AppVersion appVersion, com.google.apphosting.base.protos.RuntimePb.UPRequest upRequest, MutableUpResponse upResponse, TraceWriter traceWriter, CpuRatioTimer requestTimer, String requestId, List<Future<?>> asyncFutures, Semaphore outstandingApiRpcSemaphore, ThreadGroup requestThreadGroup, RequestState requestState, Long millisUntilSoftDeadline)	Creates an ApiProxy.Environment instance that is suitable for use with this class.
void	disable()
void	enable()
void	flushLogs(ApiProxyImpl.EnvironmentImpl environment)
List<Thread>	getRequestThreads(ApiProxyImpl.EnvironmentImpl environment)
void	log(ApiProxyImpl.EnvironmentImpl environment, com.google.apphosting.api.ApiProxy.LogRecord record)
Future<byte[]>	makeAsyncCall(ApiProxyImpl.EnvironmentImpl environment, String packageName, String methodName, byte[] request, com.google.apphosting.api.ApiProxy.ApiConfig apiConfig)
byte[]	makeSyncCall(ApiProxyImpl.EnvironmentImpl environment, String packageName, String methodName, byte[] request)
void	setRequestManager(RequestThreadManager requestThreadManager)

Methods inherited from class java.lang.Object

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

Field Details

BACKEND_ID_KEY

public static final String BACKEND_ID_KEY

See Also:

• Constant Field Values

INSTANCE_ID_KEY

public static final String INSTANCE_ID_KEY

See Also:

• Constant Field Values

CLOUD_SQL_JDBC_CONNECTIVITY_ENABLED_KEY

public static final String CLOUD_SQL_JDBC_CONNECTIVITY_ENABLED_KEY

See Also:

• Constant Field Values

Method Details

builder

public static ApiProxyImpl.Builder builder()

setRequestManager

public void setRequestManager(RequestThreadManager requestThreadManager)

disable

public void disable()

enable

public void enable()

makeSyncCall

public byte[] makeSyncCall(ApiProxyImpl.EnvironmentImpl environment,
 String packageName,
 String methodName,
 byte[] request)

Specified by:

makeSyncCall in interface com.google.apphosting.api.ApiProxy.Delegate<ApiProxyImpl.EnvironmentImpl>

makeAsyncCall

public Future<byte[]> makeAsyncCall(ApiProxyImpl.EnvironmentImpl environment,
 String packageName,
 String methodName,
 byte[] request,
 com.google.apphosting.api.ApiProxy.ApiConfig apiConfig)

Specified by:

makeAsyncCall in interface com.google.apphosting.api.ApiProxy.Delegate<ApiProxyImpl.EnvironmentImpl>

log

public void log(ApiProxyImpl.EnvironmentImpl environment,
 com.google.apphosting.api.ApiProxy.LogRecord record)

Specified by:

log in interface com.google.apphosting.api.ApiProxy.Delegate<ApiProxyImpl.EnvironmentImpl>

flushLogs

public void flushLogs(ApiProxyImpl.EnvironmentImpl environment)

Specified by:

flushLogs in interface com.google.apphosting.api.ApiProxy.Delegate<ApiProxyImpl.EnvironmentImpl>

getRequestThreads

public List<Thread> getRequestThreads(ApiProxyImpl.EnvironmentImpl environment)

Specified by:

getRequestThreads in interface com.google.apphosting.api.ApiProxy.Delegate<ApiProxyImpl.EnvironmentImpl>

createEnvironment

public ApiProxyImpl.EnvironmentImpl createEnvironment(AppVersion appVersion,
 com.google.apphosting.base.protos.RuntimePb.UPRequest upRequest,
 MutableUpResponse upResponse,
 @Nullable
 TraceWriter traceWriter,
 CpuRatioTimer requestTimer,
 String requestId,
 List<Future<?>> asyncFutures,
 Semaphore outstandingApiRpcSemaphore,
 ThreadGroup requestThreadGroup,
 RequestState requestState,
 @Nullable
 Long millisUntilSoftDeadline)

Creates an ApiProxy.Environment instance that is suitable for use with this class.