Trasier Documentation

opentracing.spring.web:
  enabled: ${TRASIER_ACTIVATED:true}
  client.enabled: ${TRASIER_ACTIVATED:true}
trasier:
  proxy:
    host: ${PROXY_HOST}
    port: ${PROXY_PORT}
  client:
    accountId: ${ACCOUNT_ID:1234}
    systemName: ${APP_NAME}
    activated: ${TRASIER_ACTIVATED:true}
    payloadTracingDisabled: ${TRASIER_PAYLOAD_TRACING_DISABLED:false}
    interceptor.sampling:
      url.skipPattern: .*/checkServlet|/callback/agent/log|/ws/stomp|/widgets/poll/WORKSTATIONCHECK

trasier:
  client:
    spaceKey: ${SPACE_KEY}
    clientId: ${CLIENT_ID}
    clientSecret: ${CLIENT_SECRET}

<!-- Trasier Dependencies -->
<dependency>
    <groupId>io.opentracing.contrib</groupId>
    <artifactId>opentracing-spring-web</artifactId>
    <version>2.1.3</version>
</dependency>
<dependency>
    <groupId>com.trasier</groupId>
    <artifactId>trasier-client-spring-grpc</artifactId>
    <version>2.1.1</version>
</dependency>
<dependency>
    <groupId>com.trasier</groupId>
    <artifactId>trasier-client-opentracing-spring-interceptor</artifactId>
    <version>2.1.1</version>
</dependency>

<!-- Trasier Dependencies -->
<dependency>
    <groupId>io.opentracing.contrib</groupId>
    <artifactId>opentracing-spring-web</artifactId>
    <version>2.1.3</version>
</dependency>
<dependency>
    <groupId>com.trasier</groupId>
    <artifactId>trasier-client-spring-rest</artifactId>
    <version>2.1.1</version>
</dependency>
<dependency>
    <groupId>com.trasier</groupId>
    <artifactId>trasier-client-opentracing-spring-interceptor</artifactId>
    <version>2.1.1</version>
</dependency>

<filter>
    <filter-name>TrasierBufferFilter</filter-name>
    <filter-class>com.trasier.opentracing.spring.interceptor.servlet.TrasierBufferFilter</filter-class>
</filter>
<filter-mapping>
    <filter-name>TrasierBufferFilter</filter-name>
    <url-pattern>/*</url-pattern>
</filter-mapping>
<filter>
    <filter-name>TracingFilter</filter-name>
    <filter-class>io.opentracing.contrib.web.servlet.filter.TracingFilter</filter-class>
</filter>
<filter-mapping>
    <filter-name>TracingFilter</filter-name>
    <url-pattern>/*</url-pattern>
</filter-mapping>
<listener>
    <listener-class>com.trasier.opentracing.spring.interceptor.servlet.TrasierSpringConfigListener</listener-class>
</listener>

<bean id="trasierClientConfiguration" class="com.trasier.client.configuration.TrasierClientConfiguration">
        <property name="accountId" value="${trasier.accountId}" />
        <property name="spaceKey" value="${trasier.spaceKey}" />
        <property name="clientId" value="${trasier.clientId}" />
        <property name="clientSecret" value="${trasier.clientSecret}" />
        <property name="systemName" value="${trasier.clientSecret}" />
        <property name="activated" value="${trasier.activated}" />
        <property name="payloadTracingDisabled" value="${trasier.payloadTracingDisabled}" />
</bean>

<bean id="trasierProxyConfiguration" class="com.trasier.client.configuration.TrasierProxyConfiguration">
        <property name="host" value="${trasier.proxyHost" />
        <property name="port" value="${trasier.proxyPort}" />
</bean>

<bean id="trasierEndpointConfiguration" class="com.trasier.client.configuration.TrasierEndpointConfiguration" />

<bean id="trasierSampleByOperationConfiguration" class="com.trasier.client.spring.spancontrol.TrasierSampleByOperationConfiguration" />

<bean id="trasierScopeManager" class="com.trasier.client.opentracing.TrasierScopeManager">
</bean>

<bean id="trasierTracer" class="com.trasier.client.opentracing.TrasierTracer">
        <constructor-arg index="0" ref="trasierSpringClient" />
        <constructor-arg index="1" ref="trasierClientConfiguration" />
        <constructor-arg index="2" ref="trasierScopeManager" />
</bean>

<context:component-scan base-package="com.trasier.client.spring"/>
<context:component-scan base-package="com.trasier.opentracing.spring.interceptor"/>

<!-- Trasier -->
<dependency>
    <groupId>com.trasier</groupId>
    <artifactId>trasier-client-spring-grpc-starter</artifactId>
    <version>2.1.1</version>
</dependency>

<!-- Trasier -->
<dependency>
    <groupId>com.trasier</groupId>
    <artifactId>trasier-client-spring-rest-starter</artifactId>
    <version>2.1.1</version>
</dependency>

@Autowired
private Tracer tracer;

private void traceableFilterMethod(Filter filter, List<String> data) {

    io.opentracing.Span span = tracer.buildSpan("MY_OPERATION_NAME")
                .withTag(Tags.SPAN_KIND.getKey(), Tags.SPAN_KIND_CLIENT)
                .start();

    Span trasierSpan = null;

    if (span instanceof TrasierSpan) {
        trasierSpan = ((TrasierSpan) span).unwrap();
    }

    if (trasierSpan != null) {
        trasierSpan.setIncomingContentType(ContentType.TEXT);
        trasierSpan.setBeginProcessingTimestamp(System.currentTimeMillis());
        trasierSpan.setIncomingData(data.toString());
    }

    Scope scope = this.tracer.activateSpan(span);

    filter.apply(data); // try-catch omitted for readability

    if (trasierSpan != null) {
        trasierSpan.setOutgoingContentType(ContentType.TEXT);
        trasierSpan.setFinishProcessingTimestamp(System.currentTimeMillis());
        trasierSpan.setOutgoingData(data.toString());
        trasierSpan.setStatus(TrasierConstants.STATUS_OK);

        io.opentracing.ScopeManager scopeManager = tracer.scopeManager();
        if (scopeManager instanceof TrasierScopeManager) {
            ((TrasierScopeManager) scopeManager).activeScope().close();
        }

        span.finish();

    }

}

@Autowired
private Tracer tracer;

@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) {

    CachedServletRequestWrapper request = createCachedRequest((HttpServletRequest) servletRequest);
    CachedServletResponseWrapper response = createCachedResponse((HttpServletResponse) servletResponse);

    io.opentracing.Span span = tracer.buildSpan("MY_OPERATION_NAME")
                .withTag(Tags.SPAN_KIND.getKey(), Tags.SPAN_KIND_CLIENT)
                .start();

    Span trasierSpan = null;

    if (span instanceof TrasierSpan) {
        trasierSpan = ((TrasierSpan) span).unwrap();
    }

    if (trasierSpan != null) {
        currentSpan.setIncomingData(new String(request.getContentAsByteArray()));
        currentSpan.setIncomingHeader(getRequestHeaders(request));
        currentSpan.setIncomingContentType(ContentType.XML);
        currentSpan.setBeginProcessingTimestamp(System.currentTimeMillis());
    }

    filterChain.doFilter(request, response); // try-catch omitted for readability

    if (trasierSpan != null) {
        trasierSpan.setOutgoingData(response.getContentAsByteArray());
        trasierSpan.setOutgoingHeader(extractHeaders(messageContext.getResponse()));
        trasierSpan.setOutgoingContentType(ContentType.XML);
        trasierSpan.setFinishProcessingTimestamp(System.currentTimeMillis());
        trasierSpan.setStatus(TrasierConstants.STATUS_OK);

        io.opentracing.ScopeManager scopeManager = tracer.scopeManager();
        if (scopeManager instanceof TrasierScopeManager) {
            ((TrasierScopeManager) scopeManager).activeScope().close();
        }
        span.finish();
    }
}