Package cloud.filibuster.instrumentation.libraries.armeria.http

Class FilibusterDecoratingHttpService

java.lang.Object

com.linecorp.armeria.common.util.AbstractUnwrappable<com.linecorp.armeria.server.Service<T_I,T_O>>

com.linecorp.armeria.server.DecoratingService<I,O,I,O>

com.linecorp.armeria.server.SimpleDecoratingService<com.linecorp.armeria.common.HttpRequest,com.linecorp.armeria.common.HttpResponse>

com.linecorp.armeria.server.SimpleDecoratingHttpService

cloud.filibuster.instrumentation.libraries.armeria.http.FilibusterDecoratingHttpService

All Implemented Interfaces:

com.linecorp.armeria.common.util.Unwrappable, com.linecorp.armeria.server.HttpService, com.linecorp.armeria.server.Service<com.linecorp.armeria.common.HttpRequest,com.linecorp.armeria.common.HttpResponse>

public class FilibusterDecoratingHttpService
extends com.linecorp.armeria.server.SimpleDecoratingHttpService

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
FilibusterDecoratingHttpService(com.linecorp.armeria.server.HttpService delegate)
FilibusterDecoratingHttpService(com.linecorp.armeria.server.HttpService delegate, java.lang.String serviceName)

Method Summary

Modifier and Type	Method	Description
protected void	contextWhenComplete(com.linecorp.armeria.server.ServiceRequestContext ctx)
protected com.linecorp.armeria.common.HttpResponse	delegateWithContext(com.linecorp.armeria.server.ServiceRequestContext ctx, com.linecorp.armeria.common.HttpRequest req)
java.lang.String	getDistributedExecutionIndexFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)
java.lang.String	getGeneratedIdFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)
java.lang.String	getOriginVectorClockFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)
java.lang.String	getRequestIdFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)
java.lang.String	getVectorClockFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)
com.linecorp.armeria.common.HttpResponse	serve(com.linecorp.armeria.server.ServiceRequestContext ctx, com.linecorp.armeria.common.HttpRequest req)
protected void	setupContext(com.linecorp.armeria.server.ServiceRequestContext ctx, com.linecorp.armeria.common.HttpRequest req)

Methods inherited from class com.linecorp.armeria.server.DecoratingService

serviceAdded, shouldCachePath

Methods inherited from class com.linecorp.armeria.common.util.AbstractUnwrappable

as, toString, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linecorp.armeria.server.HttpService

decorate, decorate

Methods inherited from interface com.linecorp.armeria.server.Service

as, serviceAdded, shouldCachePath, unwrap

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

FilibusterDecoratingHttpService

public FilibusterDecoratingHttpService(com.linecorp.armeria.server.HttpService delegate)

FilibusterDecoratingHttpService

public FilibusterDecoratingHttpService(com.linecorp.armeria.server.HttpService delegate,
                                       java.lang.String serviceName)

Method Detail

setupContext

protected void setupContext(com.linecorp.armeria.server.ServiceRequestContext ctx,
                            com.linecorp.armeria.common.HttpRequest req)

contextWhenComplete

protected void contextWhenComplete(com.linecorp.armeria.server.ServiceRequestContext ctx)

delegateWithContext

protected com.linecorp.armeria.common.HttpResponse delegateWithContext(com.linecorp.armeria.server.ServiceRequestContext ctx,
                                                                       com.linecorp.armeria.common.HttpRequest req)
                                                                throws java.lang.Exception

Throws:

java.lang.Exception

getRequestIdFromRequestMetadata

public java.lang.String getRequestIdFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)

getGeneratedIdFromRequestMetadata

public java.lang.String getGeneratedIdFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)

getVectorClockFromRequestMetadata

public java.lang.String getVectorClockFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)

getOriginVectorClockFromRequestMetadata

public java.lang.String getOriginVectorClockFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)

getDistributedExecutionIndexFromRequestMetadata

public java.lang.String getDistributedExecutionIndexFromRequestMetadata(com.linecorp.armeria.common.HttpRequest req)

serve

public com.linecorp.armeria.common.HttpResponse serve(com.linecorp.armeria.server.ServiceRequestContext ctx,
                                                      com.linecorp.armeria.common.HttpRequest req)
                                               throws java.lang.Exception

Throws:

java.lang.Exception