Package cloud.filibuster.instrumentation.instrumentors

Class FilibusterServerInstrumentor

  • public final class FilibusterServerInstrumentor
extends java.lang.Object
    Server instrumentor for Filibuster.

    • Constructor Summary

      Constructors 
      Constructor Description
      FilibusterServerInstrumentor​(java.lang.String serviceName, boolean shouldCommunicateWithServer, java.lang.String requestId, java.lang.String generatedId, java.lang.String vclockStr, java.lang.String originVclockStr, java.lang.String distributedExecutionIndex, ContextStorage contextStorage)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void beforeInvocation()
      Invoked before the server processes the request to contact the Filibuster server and notify it as to what service this request has been terminated at.
      java.lang.String getDistributedExecutionIndex()
      Returns the execution index associated with the request.
      java.lang.String getGeneratedId()
      Returns the generated identifier associated with the request.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • FilibusterServerInstrumentor

        public FilibusterServerInstrumentor​(java.lang.String serviceName,
                                    boolean shouldCommunicateWithServer,
                                    java.lang.String requestId,
                                    java.lang.String generatedId,
                                    @Nullable
                                    java.lang.String vclockStr,
                                    @Nullable
                                    java.lang.String originVclockStr,
                                    java.lang.String distributedExecutionIndex,
                                    ContextStorage contextStorage)
        Parameters:
        serviceName - name of the service that is running the server instrumentor.
        shouldCommunicateWithServer - whether the Filibuster server should be contacted.
        requestId - the request identifier.
        generatedId - the generated identifier for the request.
        vclockStr - a serialized vector clock.
        originVclockStr - a serialized origin vector clock.
        distributedExecutionIndex - a serialized execution index.

    • Method Detail

      • getGeneratedId

        public java.lang.String getGeneratedId()
        Returns the generated identifier associated with the request. This will be null unless provided by the caller.
        Returns:
        generated identifier associated with the request.

      • getDistributedExecutionIndex

        public java.lang.String getDistributedExecutionIndex()
        Returns the execution index associated with the request. This will be null unless provided by the caller.
        Returns:
        execution index associated with this request.

      • beforeInvocation

        public void beforeInvocation()
        Invoked before the server processes the request to contact the Filibuster server and notify it as to what service this request has been terminated at.