aboutsummaryrefslogtreecommitdiff
path: root/kamon-spray
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2013-12-25 13:15:19 -0300
committerIvan Topolnjak <ivantopo@gmail.com>2013-12-25 13:15:19 -0300
commitb8963079732f0a556625b64577fb94575c0e72ee (patch)
tree52eebcc659becb84bf6a32f8e5e843347b3ea3aa /kamon-spray
parent910830c979699db04a6745cf922631731fda4cd0 (diff)
downloadKamon-b8963079732f0a556625b64577fb94575c0e72ee.tar.gz
Kamon-b8963079732f0a556625b64577fb94575c0e72ee.tar.bz2
Kamon-b8963079732f0a556625b64577fb94575c0e72ee.zip
remove old, unused instrumentation
Diffstat (limited to 'kamon-spray')
-rw-r--r--kamon-spray/src/main/scala/kamon/instrumentation/SprayServerInstrumentation.scala86
1 files changed, 0 insertions, 86 deletions
diff --git a/kamon-spray/src/main/scala/kamon/instrumentation/SprayServerInstrumentation.scala b/kamon-spray/src/main/scala/kamon/instrumentation/SprayServerInstrumentation.scala
deleted file mode 100644
index c47dbc67..00000000
--- a/kamon-spray/src/main/scala/kamon/instrumentation/SprayServerInstrumentation.scala
+++ /dev/null
@@ -1,86 +0,0 @@
-/* ===================================================
- * Copyright © 2013 the kamon project <http://kamon.io/>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ========================================================== */
-package spray.can.server
-
-import org.aspectj.lang.annotation._
-import org.aspectj.lang.ProceedingJoinPoint
-import spray.http.HttpRequest
-import spray.http.HttpHeaders.Host
-import kamon.trace.{ TraceContext, Trace, ContextAware, TimedContextAware }
-
-//import spray.can.client.HttpHostConnector.RequestContext
-
-@Aspect
-class SprayOpenRequestContextTracing {
-
- @DeclareMixin("spray.can.client.HttpHostConnector.RequestContext")
- def mixinContextAwareToRequestContext: TimedContextAware = new TimedContextAware {
- val timestamp: Long = System.nanoTime()
- val traceContext: Option[TraceContext] = Trace.context()
- }
-}
-
-@Aspect
-class SprayServerInstrumentation {
-
- @Pointcut("execution(spray.can.client.HttpHostConnector.RequestContext.new(..)) && this(ctx) && args(request, *, *, *)")
- def requestRecordInit(ctx: TimedContextAware, request: HttpRequest): Unit = {}
-
- @After("requestRecordInit(ctx, request)")
- def whenCreatedRequestRecord(ctx: TimedContextAware, request: HttpRequest): Unit = {
- // Necessary to force the initialization of TracingAwareRequestContext at the moment of creation.
- /*for{
- tctx <- ctx.traceContext
- host <- request.header[Host]
- } tctx.tracer ! WebExternalStart(ctx.timestamp, host.host)*/
- }
-
- @Pointcut("execution(* spray.can.client.HttpHostConnectionSlot.dispatchToCommander(..)) && args(requestContext, message)")
- def dispatchToCommander(requestContext: TimedContextAware, message: Any): Unit = {}
-
- @Around("dispatchToCommander(requestContext, message)")
- def aroundDispatchToCommander(pjp: ProceedingJoinPoint, requestContext: TimedContextAware, message: Any) = {
- println("Completing the request with context: " + requestContext.traceContext)
-
- /*Tracer.context.withValue(requestContext.traceContext) {
- requestContext.traceContext.map {
- tctx => //tctx.tracer ! WebExternalFinish(requestContext.timestamp)
- }
- pjp.proceed()
- }*/
-
- }
-
- @Pointcut("execution(* spray.can.client.HttpHostConnector.RequestContext.copy(..)) && this(old)")
- def copyingRequestContext(old: TimedContextAware): Unit = {}
-
- @Around("copyingRequestContext(old)")
- def aroundCopyingRequestContext(pjp: ProceedingJoinPoint, old: TimedContextAware) = {
- println("Instrumenting the request context copy.")
- /*Tracer.traceContext.withValue(old.traceContext) {
- pjp.proceed()
- }*/
- }
-}
-
-@Aspect
-class SprayRequestContextTracing {
-
- @DeclareMixin("spray.can.client.HttpHostConnector.RequestContext")
- def mixin: ContextAware = new ContextAware {
- val traceContext: Option[TraceContext] = Trace.context()
- }
-} \ No newline at end of file