Plugin-Development-Guide.md

Plugin Development Guide

This document describe how to understand, develop and contribute plugin.

Concepts

Span

Span is an important and common concept in distributed tracing system. Learn Span from Google Dapper Paper and OpenTracing

SkyWalking supports OpenTracing and OpenTracing-Java API from 2017. Our Span concepts are similar with the paper and OpenTracing. Also we extend the Span.

There are three types of Span

1.1 EntrySpan EntrySpan represents a service provider, also the endpoint of server side. As an APM system, we are targeting the application servers. So almost all the services and MQ-comsumer are EntrySpan(s).

1.2 LocalSpan LocalSpan represents a normal Java method, which don't relate with remote service, neither a MQ producer/comsumer nor a service(e.g. HTTP service) provider/consumer.

1.3 ExitSpan ExitSpan represents a client of service or MQ-producer, as named as LeafSpan at early age of SkyWalking. e.g. accessing DB by JDBC, reading Redis/Memcached are cataloged an ExitSpan.

ContextCarrier

In order to implement distributed tracing, the trace across process need to be bind, and the context should propagate across the process. That is ContextCarrier's duty.

Here are the steps about how to use ContextCarrier in a A->B distributed call.

1. Create a new and empty ContextCarrier at client side.
2. Create an ExitSpan by ContextManager#createExitSpan or use ContextManager#inject to init the ContextCarrier.
3. Put all items of ContextCarrier into heads(e.g. HTTP HEAD), attachments(e.g. Dubbo RPC framework) or messages(e.g. Kafka)
4. The ContextCarrier propagates to server side by the service call.
5. At server side, get all items from heads, attachments or messages.
6. Create an EntrySpan by ContestManager#createEntrySpan or use ContextManager#extract to bind the client and server.

Let's demonstrate the steps by Apache HTTPComponent client plugin and Tomcat 7 server plugin

1. Client side steps by Apache HTTPComponent client plugin

            span = ContextManager.createExitSpan("/span/operation/name", contextCarrier, "ip:port");
            CarrierItem next = contextCarrier.items();
            while (next.hasNext()) {
                next = next.next();
                httpRequest.setHeader(next.getHeadKey(), next.getHeadValue());
            }

2. Server side steps by Tomcat 7 server plugin

            ContextCarrier contextCarrier = new ContextCarrier();
            CarrierItem next = contextCarrier.items();
            while (next.hasNext()) {
                next = next.next();
                next.setHeadValue(request.getHeader(next.getHeadKey()));
            }

            span = ContextManager.createEntrySpan(“/span/operation/name”, contextCarrier);

ContextSnapshot

Besides across process, across thread but in a process need to be supported, because async process(In-memory MQ) and batch process are common in Java. Across process and across thread are similar, because they are both about propagating context. The only difference is that, don't need to serialize for across thread.

Here are the three steps about across thread propagation:

1. Use ContextManager#capture to get the ContextSnapshot object.
2. Let the sub-thread access the ContextSnapshot by any way, through method arguments or carried by an existed arguments
3. Use ContextManager#continued in sub-thread.

Core APIs

ContextManager

ContextManager provides all major and primary APIs.

1. Create EntrySpan

public static AbstractSpan createEntrySpan(String operationName, ContextCarrier carrier)

Create EntrySpan by operation name(e.g. service name, uri) and ContextCarrier.

2. Create LocalSpan

public static AbstractSpan createLocalSpan(String operationName)

Create LocalSpan by operation name(e.g. full method signature)

3. Create ExitSpan

public static AbstractSpan createExitSpan(String operationName, ContextCarrier carrier, String remotePeer)

Create ExitSpan by operation name(e.g. service name, uri) and new ContextCarrier and peer address (e.g. ip+port, hostname+port)

AbstractSpan

    /**
     * Set the component id, which defines in {@link ComponentsDefine}
     *
     * @param component
     * @return the span for chaining.
     */
    AbstractSpan setComponent(Component component);

    /**
     * Only use this method in explicit instrumentation, like opentracing-skywalking-bridge.
     * It it higher recommend don't use this for performance consideration.
     *
     * @param componentName
     * @return the span for chaining.
     */
    AbstractSpan setComponent(String componentName);

    AbstractSpan setLayer(SpanLayer layer);

    /**
     * Set a key:value tag on the Span.
     *
     * @return this Span instance, for chaining
     */
    AbstractSpan tag(String key, String value);

    /**
     * Record an exception event of the current walltime timestamp.
     *
     * @param t any subclass of {@link Throwable}, which occurs in this span.
     * @return the Span, for chaining
     */
    AbstractSpan log(Throwable t);

    AbstractSpan errorOccurred();

    /**
     * Record an event at a specific timestamp.
     *
     * @param timestamp The explicit timestamp for the log record.
     * @param event the events
     * @return the Span, for chaining
     */
    AbstractSpan log(long timestamp, Map<String, ?> event);

    /**
     * Sets the string name for the logical operation this span represents.
     *
     * @return this Span instance, for chaining
     */
    AbstractSpan setOperationName(String operationName);

Besides set operation name, tags and logs, two attributes shoule be set, which are component and layer, especially for EntrySpan and ExitSpan

SpanLayer is the catalog of span. Here are 5 values:

1. UNKNOWN (default)
2. DB
3. RPC_FRAMEWORK, for a RPC framework, not an ordinary HTTP
4. HTTP
5. MQ

Component IDs are defined and protected by SkyWalking project, 0 -> 10000 IDs are reserved. If you want to contribute a new plugin, you can ask for an official ID, after your pull request approved and automatic test cases accepted by PMC. Please use > 10000 ID, if you are going to develop a private plugin or don't intend to contribute the plugin to community, to avoid the ID conflict.

Develop a plugin

Abstract

The basic method to trace is intercepting a Java method, by using byte code manipulation tech and AOP concept. SkyWalking boxed the byte code manipulation tech and tracing context propagation, so you just need to define the intercept point(a.k.a. aspect pointcut in Spring)

Intercept

SkyWalking provide two common defines to intercept Contructor, instance method and class method.

• Extend ClassInstanceMethodsEnhancePluginDefine defines Contructor intercept points and instance method intercept points.
• Extend ClassStaticMethodsEnhancePluginDefine definec class method intercept points.

Of course, you can extend ClassEnhancePluginDefine to set all intercept points. But it is unusual.

Implement plugin

I will demonstrate about how to implement a plugin by extending ClassInstanceMethodsEnhancePluginDefine

1. Define the target class name

protected abstract ClassMatch enhanceClass();

ClassMatch represents how to match the target classes, there are 4 ways:

• byName, through the full class name(package name + . + class name)
• byClassAnnotationMatch, through the class existed certain annotations.
• byMethodAnnotationMatch, through the class's method existed certain annotations.
• byHierarchyMatch, throught the class's parent classes or interfaces

Attentions:

• Forbid to use *.class.getName() to get the class String name. Recommend you to use literal String. This is for avoiding ClassLoader issues.
• by*AnnotationMatch doesn't support the inherited annotations.
• Don't recommend use byHierarchyMatch, unless it is really necessary. Because using it may trigger intercepting many unexcepted methods, which causes performance issues and concerns.

Example：

@Override
protected ClassMatch enhanceClassName() {
    return byName("org.apache.catalina.core.StandardEngineValve");		
}		      

2. Define an instance method intercept point

protected InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints();

public interface InstanceMethodsInterceptPoint {
    /**
     * class instance methods matcher.
     *
     * @return methods matcher
     */
    ElementMatcher<MethodDescription> getMethodsMatcher();

    /**
     * @return represents a class name, the class instance must instanceof InstanceMethodsAroundInterceptor.
     */
    String getMethodsInterceptor();

    boolean isOverrideArgs();
}

Also use Matcher to set the target methods. Return true in isOverrideArgs, if you want to change the argument ref in interceptor.

The following sections will tell you how to implement the interceptor.

3. Add plugin define into skywalking-plugin.def file

tomcat-7.x/8.x=TomcatInstrumentation

Implement an interceptor

As an interceptor for an instance method, the interceptor implements org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor

/**
 * A interceptor, which intercept method's invocation. The target methods will be defined in {@link
 * ClassEnhancePluginDefine}'s subclass, most likely in {@link ClassInstanceMethodsEnhancePluginDefine}
 *
 * @author wusheng
 */
public interface InstanceMethodsAroundInterceptor {
    /**
     * called before target method invocation.
     *
     * @param result change this result, if you want to truncate the method.
     * @throws Throwable
     */
    void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
        MethodInterceptResult result) throws Throwable;

    /**
     * called after target method invocation. Even method's invocation triggers an exception.
     *
     * @param ret the method's original return value.
     * @return the method's actual return value.
     * @throws Throwable
     */
    Object afterMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
        Object ret) throws Throwable;

    /**
     * called when occur exception.
     *
     * @param t the exception occur.
     */
    void handleMethodException(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
        Throwable t);
}

Use the core APIs in before, after and exception handle stages.

Contribute plugins into Apache SkyWalking repository

We are welcome everyone to contribute plugins.

Please follow there steps:

1. Submit an issue about which plugins are you going to contribute, including supported version.
2. Create sub modules under apm-sniffer/apm-sdk-plugin, and the name should include supported library name and versions
3. Follow this guide to develop. Make sure comments and test cases are provided.
4. Develop and test.
5. Send the pull request and ask for review, and provide the automatic test cases by following PMC members guides.
6. The plugin committers approves your plugins after automatic test cases provided and the tests passed in our CI.
7. The plugin accepted by SkyWalking.