Skip navigation links
A C D E F G I L M N O P R S T U V W 

A

AclTrustManagerFactory - Class in io.token.rpc.ssl
TrustManagerFactory that builds AclTrustManager that wraps default TrustManager and adds ACL business logic.
apply(T) - Method in interface io.token.rpc.util.ErrorMapper.Function
 

C

CLIENT - Static variable in interface io.token.rpc.util.Tracing.TraceOriginator
 
CN_CONTEXT - Static variable in class io.token.rpc.util.Ssl
 
Constants - Class in io.token.rpc
Global RPC constants.
Constants() - Constructor for class io.token.rpc.Constants
 
CONTEXT_TRACE_ID - Static variable in class io.token.rpc.util.Tracing
 
ContextConfig - Class in io.token.rpc
 
ContextConfig() - Constructor for class io.token.rpc.ContextConfig
 
ContextConfig.Scope - Enum in io.token.rpc
 
ContextKeys - Enum in io.token.rpc
 
Converters - Class in io.token.rpc.util
 
create(MethodDescriptor<ReqT, ResT>) - Method in interface io.token.rpc.interceptor.InterceptorFactory
 
create(boolean) - Static method in class io.token.rpc.RpcLogConfig
 
create(File, File, File, List<String>) - Static method in class io.token.rpc.SslConfig
Create an instance of ssl config.

D

defaultConfig() - Static method in class io.token.rpc.ContextConfig
Return the default ContextConfig.
defaultConfig() - Static method in class io.token.rpc.RpcLogConfig
Create a default RpcLogConfig instance.

E

Endpoint - Enum in io.token.rpc
 
engineGetTrustManagers() - Method in class io.token.rpc.ssl.AclTrustManagerFactory
 
engineInit(KeyStore) - Method in class io.token.rpc.ssl.AclTrustManagerFactory
 
engineInit(ManagerFactoryParameters) - Method in class io.token.rpc.ssl.AclTrustManagerFactory
 
ErrorMapper<T extends java.lang.Exception> - Class in io.token.rpc.util
Maps a business error into a gRPC status.
ErrorMapper(Class<T>, ErrorMapper.Function<T>) - Constructor for class io.token.rpc.util.ErrorMapper
Creates a new instance of the ErrorMapper.
errorMapper(Class<T>, ErrorMapper.Function<T>) - Static method in class io.token.rpc.util.ErrorMapper
A static factory method to create ErrorMapper instances.
ErrorMapper.Function<T> - Interface in io.token.rpc.util
 
execute(StreamObserver<T>, Callable<T>) - Static method in class io.token.rpc.util.Converters
Executes an action.

F

from(Config) - Static method in class io.token.rpc.ContextConfig
Create a ContextConfig instance from parsing a config file.
from(Config) - Static method in class io.token.rpc.RpcLogConfig
Create an RpcLogConfig instance.
from(Config) - Static method in class io.token.rpc.SslConfig
Creates an instance from config file.
from(String, String, String, List<String>) - Static method in class io.token.rpc.SslConfig
Creates an instance from filenames.

G

getAcl() - Method in class io.token.rpc.SslConfig
 
getCertFile() - Method in class io.token.rpc.SslConfig
 
getCommonName(X509Certificate) - Static method in class io.token.rpc.util.Ssl
Extract subject's Common Name from X509Certificate.
getCommonName(X509Certificate) - Static method in class io.token.rpc.util.Ssl
Extract subject's Common Name from X509Certificate.
getContextKey() - Method in enum io.token.rpc.ContextKeys
 
getErrorClass() - Method in class io.token.rpc.util.ErrorMapper
Returns the type of the error handled by this mapper.
getInstance(File, List<String>) - Static method in class io.token.rpc.ssl.AclTrustManagerFactory
Get instance of AclTrustManagerFactory.
getKey() - Method in enum io.token.rpc.ContextKeys
 
getKeyFile() - Method in class io.token.rpc.SslConfig
 
getMetadataKey() - Method in enum io.token.rpc.ContextKeys
 
getPublicKeys() - Static method in enum io.token.rpc.ContextKeys
Returns set of public context keys.
getScope() - Method in class io.token.rpc.ContextConfig
 
getTrustedCertFile() - Method in class io.token.rpc.SslConfig
 

I

INSTANCE - Static variable in class io.token.rpc.util.Unit
 
InterceptorFactory - Interface in io.token.rpc.interceptor
Creates SimpleInterceptor instances.
io.token.protobuf - package io.token.protobuf
 
io.token.rpc - package io.token.rpc
 
io.token.rpc.interceptor - package io.token.rpc.interceptor
 
io.token.rpc.spi - package io.token.rpc.spi
 
io.token.rpc.ssl - package io.token.rpc.ssl
 
io.token.rpc.util - package io.token.rpc.util
 

L

logError(Status, Metadata) - Method in class io.token.rpc.RpcLogger
Logs error response.
loggerFor(Endpoint, String, RpcLogConfig) - Static method in class io.token.rpc.RpcLogger
Creates new logger.
loggerFor(Endpoint, String, String, RpcLogConfig) - Static method in class io.token.rpc.RpcLogger
Creates new logger.
LoggingInterceptor<ReqT,ResT> - Class in io.token.rpc.interceptor
Logs RPC request/responses.
LoggingInterceptor(Endpoint, MethodDescriptor<ReqT, ResT>, RpcLogConfig) - Constructor for class io.token.rpc.interceptor.LoggingInterceptor
Creates an instance.
logRequest(Object, Metadata) - Method in class io.token.rpc.RpcLogger
Logs request.
logResponse(Status, Object, Metadata) - Method in class io.token.rpc.RpcLogger
Logs response.
logResponse(Object, Metadata) - Method in class io.token.rpc.RpcLogger
Logs successful response.
logRetry(Object, Metadata, long) - Method in class io.token.rpc.RpcLogger
Logs retry request.
lookupProviderService() - Static method in class io.token.rpc.spi.ServiceLocator
Looks up a provider service from classpath.

M

ManagedChannelBuilderProvider - Interface in io.token.rpc.spi
An SPI provider for a ManagedChannelBuilder.
map(Throwable) - Method in class io.token.rpc.util.ErrorMapper
Maps an error into a gRPC status.
METADATA_TRACE_ID - Static variable in class io.token.rpc.util.Tracing
 
MetadataInterceptor<ReqT,ResT> - Class in io.token.rpc.interceptor
Appends metadata (headers) to a call.
MetadataInterceptor(Metadata) - Constructor for class io.token.rpc.interceptor.MetadataInterceptor
Creates an instance.

N

newFactory(Endpoint, RpcLogConfig) - Static method in class io.token.rpc.interceptor.LoggingInterceptor
Creates an InterceptorFactory with a given endpoint.
newFactory(Metadata) - Static method in class io.token.rpc.interceptor.MetadataInterceptor
Creates an InterceptorFactory with a given endpoint.
newTraceId() - Static method in class io.token.rpc.util.Tracing
Creates new tracing id.

O

onAfterField(Descriptors.FieldDescriptor, Object) - Method in class io.token.protobuf.ProtoVisitor
Invoked after every field, complex or simple.
onBeforeField(Descriptors.FieldDescriptor, Object) - Method in class io.token.protobuf.ProtoVisitor
Invoked before every field, complex or simple.
onComplete(Status, ReqT, ResT, Metadata) - Method in class io.token.rpc.interceptor.LoggingInterceptor
 
onComplete(Status, ReqT, ResT, Metadata) - Method in class io.token.rpc.interceptor.SimpleInterceptor
Invoked when request is finished.
onFieldBoolean(Descriptors.FieldDescriptor, Boolean) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every boolean based field.
onFieldBytes(Descriptors.FieldDescriptor, byte[]) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every byte array based field.
onFieldDouble(Descriptors.FieldDescriptor, Double) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every double based field.
onFieldEnum(Descriptors.FieldDescriptor, Descriptors.EnumValueDescriptor) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every enum based field.
onFieldFloat(Descriptors.FieldDescriptor, Float) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every float based field.
onFieldInteger(Descriptors.FieldDescriptor, Integer) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every integer based field.
onFieldLong(Descriptors.FieldDescriptor, Long) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every long based field.
onFieldString(Descriptors.FieldDescriptor, String) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every string based field.
onHalfClose(ReqT, Metadata) - Method in class io.token.rpc.interceptor.LoggingInterceptor
 
onHalfClose(ReqT, Metadata) - Method in class io.token.rpc.interceptor.MetadataInterceptor
 
onHalfClose(ReqT, Metadata) - Method in class io.token.rpc.interceptor.SimpleInterceptor
gRPC invokes the actual method implementation in the onHalfClose method.
onMessageEnd(Descriptors.FieldDescriptor, Message) - Method in class io.token.protobuf.ProtoVisitor
Invoked at the end of a nested message field.
onMessageStart(Descriptors.FieldDescriptor, Message) - Method in class io.token.protobuf.ProtoVisitor
Invoked at the end of a nested message field.
onRepeatedFieldEnd(Descriptors.FieldDescriptor) - Method in class io.token.protobuf.ProtoVisitor
Invoked at the end of a repeated field.
onRepeatedFieldStart(Descriptors.FieldDescriptor) - Method in class io.token.protobuf.ProtoVisitor
Invoked at the start of a repeated field.
onSimpleField(Descriptors.FieldDescriptor, Object) - Method in class io.token.protobuf.ProtoVisitor
Invoked for every simple field (non repeated or nested message).
onStart(ReqT, Metadata) - Method in class io.token.rpc.interceptor.LoggingInterceptor
 
onStart(ReqT, Metadata) - Method in class io.token.rpc.interceptor.MetadataInterceptor
 
onStart(ReqT, Metadata) - Method in class io.token.rpc.interceptor.SimpleInterceptor
Invoked when request is starting.

P

Protos - Class in io.token.protobuf
Protobuf related helper methods.
protoToString(Message, boolean) - Static method in class io.token.protobuf.Protos
Outputs protobuf content into a string.
ProtoTraverser - Class in io.token.protobuf
Traverses a protobuf message.
ProtoTraverser(ProtoVisitor) - Constructor for class io.token.protobuf.ProtoTraverser
Creates new traverser.
ProtoVisitor - Class in io.token.protobuf
ProtoTraverser callback API.
ProtoVisitor() - Constructor for class io.token.protobuf.ProtoVisitor
 
provide(String) - Method in interface io.token.rpc.spi.ManagedChannelBuilderProvider
Provides a new ManagedChannelBuilder for the given target.
provideConfiguredTls(String, SslConfig) - Method in interface io.token.rpc.spi.ManagedChannelBuilderProvider
Provides a new ManagedChannelBuilder for the given target an ssl configuration.
provideTls(String) - Method in interface io.token.rpc.spi.ManagedChannelBuilderProvider
Provides a new ManagedChannelBuilder for the given target an ssl configuration.

R

redactProto() - Method in class io.token.rpc.RpcLogConfig
 
RpcLogConfig - Class in io.token.rpc
 
RpcLogConfig() - Constructor for class io.token.rpc.RpcLogConfig
 
RpcLogger - Class in io.token.rpc
gRPC message logger.

S

SERVER - Static variable in interface io.token.rpc.util.Tracing.TraceOriginator
 
ServiceLocator - Class in io.token.rpc.spi
A service locator to aid with rpc service implementation library lookup.
SimpleInterceptor<ReqT,ResT> - Class in io.token.rpc.interceptor
Simple interceptor that works on both client and server.
SimpleInterceptor() - Constructor for class io.token.rpc.interceptor.SimpleInterceptor
 
Ssl - Class in io.token.rpc.util
 
Ssl() - Constructor for class io.token.rpc.util.Ssl
 
SslConfig - Class in io.token.rpc
Wraps ssl config values.
SslConfig() - Constructor for class io.token.rpc.SslConfig
 

T

toCompletable(ListenableFuture<T>) - Static method in class io.token.rpc.util.Converters
Converts future to Completable.
TOKEN_CUSTOM_ERROR_HEADER_NAME - Static variable in class io.token.rpc.Constants
Custom token error header name.
TOKEN_ERROR_DETAILS_HEADER_NAME - Static variable in class io.token.rpc.Constants
Token error details header name (available only in non-prod deployments).
TOKEN_ERROR_STACKTRACE_HEADER_NAME - Static variable in class io.token.rpc.Constants
Token error details header name (available only in non-prod deployments).
TOKEN_HTTP_HEADER_ENCODING - Static variable in class io.token.rpc.Constants
Token error HTTP header encoding.
TokenException - Exception in io.token.rpc
Custom token exception.
TokenException(Status, String) - Constructor for exception io.token.rpc.TokenException
 
toObservable(Completable, T) - Static method in class io.token.rpc.util.Converters
Converts Completable to Observable.
toObservable(ListenableFuture<T>) - Static method in class io.token.rpc.util.Converters
Converts future to Observable.
toObserver(StreamObserver<T>) - Static method in class io.token.rpc.util.Converters
Gets Observer for a given stream.
toObserver(StreamObserver<T>, T) - Static method in class io.token.rpc.util.Converters
Gets CompletableObserver for a given stream.
toSingle(ListenableFuture<T>) - Static method in class io.token.rpc.util.Converters
Creates a single from a listenable future.
toString() - Method in enum io.token.rpc.Endpoint
 
TRACE_ID_KEY - Static variable in class io.token.rpc.util.Tracing
 
TRACE_ID_KEY_SHORT - Static variable in class io.token.rpc.util.Tracing
 
TRACE_ID_LENGTH - Static variable in class io.token.rpc.util.Tracing
 
TRACE_ORIGINATOR_KEY - Static variable in class io.token.rpc.util.Tracing
 
Tracing - Class in io.token.rpc.util
 
Tracing.TraceOriginator - Interface in io.token.rpc.util
 
traverse(MessageOrBuilder) - Method in class io.token.protobuf.ProtoTraverser
Traverses the supplied protobuf, visiting every field.

U

Unit - Class in io.token.rpc.util
This unit type is used to indicate a void result type of an Observable.

V

valueOf(String) - Static method in enum io.token.rpc.ContextConfig.Scope
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.token.rpc.ContextKeys
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.token.rpc.Endpoint
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.token.rpc.ContextConfig.Scope
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.token.rpc.ContextKeys
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.token.rpc.Endpoint
Returns an array containing the constants of this enum type, in the order they are declared.

W

withMdc(Metadata, Runnable) - Static method in class io.token.rpc.util.Tracing
Sets MDC context for the supplied metadata and runs the passed it action.
withMdc(Metadata, Callable<T>) - Static method in class io.token.rpc.util.Tracing
Sets MDC context for the supplied metadata and runs the passed it action.
A C D E F G I L M N O P R S T U V W 
Skip navigation links