Package cloud.filibuster.instrumentation.libraries.grpc

Class FilibusterServerInterceptor

java.lang.Object

cloud.filibuster.instrumentation.libraries.grpc.FilibusterServerInterceptor

All Implemented Interfaces:

io.grpc.ServerInterceptor

public class FilibusterServerInterceptor
extends java.lang.Object
implements io.grpc.ServerInterceptor

Field Summary

Fields

Modifier and Type	Field	Description
protected ContextStorage	contextStorage
static java.lang.Boolean	disableInstrumentation
static java.lang.Boolean	disableServerCommunication
protected java.lang.String	serviceName

Constructor Summary

Constructors

Constructor	Description
FilibusterServerInterceptor()
FilibusterServerInterceptor(java.lang.String serviceName)

Method Summary

Modifier and Type	Method	Description
java.lang.String	getDistributedExecutionIndexFromMetadata(io.grpc.Metadata requestHeaders)
java.lang.String	getGeneratedIdFromMetadata(io.grpc.Metadata requestHeaders)
java.lang.String	getOriginVectorClockFromMetadata(io.grpc.Metadata requestHeaders)
java.lang.String	getRequestIdFromMetadata(io.grpc.Metadata requestHeaders)
java.lang.String	getVectorClockFromMetadata(io.grpc.Metadata requestHeaders)
<REQUEST,RESPONSE> io.grpc.ServerCall.Listener<REQUEST>	interceptCall(io.grpc.ServerCall<REQUEST,RESPONSE> call, io.grpc.Metadata headers, io.grpc.ServerCallHandler<REQUEST,RESPONSE> next)

Methods inherited from class java.lang.Object

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

Field Detail

serviceName

protected java.lang.String serviceName

contextStorage

protected ContextStorage contextStorage

disableServerCommunication

public static java.lang.Boolean disableServerCommunication

disableInstrumentation

public static java.lang.Boolean disableInstrumentation

Constructor Detail

FilibusterServerInterceptor

public FilibusterServerInterceptor()

FilibusterServerInterceptor

public FilibusterServerInterceptor(java.lang.String serviceName)

Method Detail

getRequestIdFromMetadata

public java.lang.String getRequestIdFromMetadata(io.grpc.Metadata requestHeaders)

getGeneratedIdFromMetadata

public java.lang.String getGeneratedIdFromMetadata(io.grpc.Metadata requestHeaders)

getVectorClockFromMetadata

public java.lang.String getVectorClockFromMetadata(io.grpc.Metadata requestHeaders)

getOriginVectorClockFromMetadata

public java.lang.String getOriginVectorClockFromMetadata(io.grpc.Metadata requestHeaders)

getDistributedExecutionIndexFromMetadata

public java.lang.String getDistributedExecutionIndexFromMetadata(io.grpc.Metadata requestHeaders)

interceptCall

public <REQUEST,RESPONSE> io.grpc.ServerCall.Listener<REQUEST> interceptCall(io.grpc.ServerCall<REQUEST,RESPONSE> call,
                                                                                   io.grpc.Metadata headers,
                                                                                   io.grpc.ServerCallHandler<REQUEST,RESPONSE> next)

Specified by:

interceptCall in interface io.grpc.ServerInterceptor