c
com.digitalasset.canton.crypto.kms.aws.tracing
AwsTraceContextInterceptor
Companion object AwsTraceContextInterceptor
class AwsTraceContextInterceptor extends ExecutionInterceptor with NamedLogging with Spanning
Starts a new trace span before each request and end it when receiving the response
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- AwsTraceContextInterceptor
- Spanning
- NamedLogging
- ExecutionInterceptor
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new AwsTraceContextInterceptor(loggerFactory: NamedLoggerFactory, tracerProvider: TracerProvider)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def afterExecution(context: AfterExecution, executionAttributes: ExecutionAttributes): Unit
- Definition Classes
- AwsTraceContextInterceptor → ExecutionInterceptor
- def afterMarshalling(arg0: AfterMarshalling, arg1: ExecutionAttributes): Unit
- Definition Classes
- ExecutionInterceptor
- def afterTransmission(arg0: AfterTransmission, arg1: ExecutionAttributes): Unit
- Definition Classes
- ExecutionInterceptor
- def afterUnmarshalling(arg0: AfterUnmarshalling, arg1: ExecutionAttributes): Unit
- Definition Classes
- ExecutionInterceptor
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def beforeExecution(context: BeforeExecution, executionAttributes: ExecutionAttributes): Unit
- Definition Classes
- AwsTraceContextInterceptor → ExecutionInterceptor
- def beforeMarshalling(arg0: BeforeMarshalling, arg1: ExecutionAttributes): Unit
- Definition Classes
- ExecutionInterceptor
- def beforeTransmission(arg0: BeforeTransmission, arg1: ExecutionAttributes): Unit
- Definition Classes
- ExecutionInterceptor
- def beforeUnmarshalling(arg0: BeforeUnmarshalling, arg1: ExecutionAttributes): Unit
- Definition Classes
- ExecutionInterceptor
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- AwsTraceContextInterceptor → NamedLogging
- def modifyAsyncHttpContent(arg0: ModifyHttpRequest, arg1: ExecutionAttributes): Optional[AsyncRequestBody]
- Definition Classes
- ExecutionInterceptor
- def modifyAsyncHttpResponseContent(arg0: ModifyHttpResponse, arg1: ExecutionAttributes): Optional[Publisher[ByteBuffer]]
- Definition Classes
- ExecutionInterceptor
- def modifyException(arg0: FailedExecution, arg1: ExecutionAttributes): Throwable
- Definition Classes
- ExecutionInterceptor
- def modifyHttpContent(arg0: ModifyHttpRequest, arg1: ExecutionAttributes): Optional[RequestBody]
- Definition Classes
- ExecutionInterceptor
- def modifyHttpRequest(arg0: ModifyHttpRequest, arg1: ExecutionAttributes): SdkHttpRequest
- Definition Classes
- ExecutionInterceptor
- def modifyHttpResponse(arg0: ModifyHttpResponse, arg1: ExecutionAttributes): SdkHttpResponse
- Definition Classes
- ExecutionInterceptor
- def modifyHttpResponseContent(arg0: ModifyHttpResponse, arg1: ExecutionAttributes): Optional[InputStream]
- Definition Classes
- ExecutionInterceptor
- def modifyRequest(arg0: ModifyRequest, arg1: ExecutionAttributes): SdkRequest
- Definition Classes
- ExecutionInterceptor
- def modifyResponse(arg0: ModifyResponse, arg1: ExecutionAttributes): SdkResponse
- Definition Classes
- ExecutionInterceptor
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def onExecutionFailure(arg0: FailedExecution, arg1: ExecutionAttributes): Unit
- Definition Classes
- ExecutionInterceptor
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withNewTrace[A](description: String)(f: (TraceContext) => (SpanWrapper) => A)(implicit tracer: Tracer): A
- Attributes
- protected
- Definition Classes
- Spanning
- def withSpan[A](description: String)(f: (TraceContext) => (SpanWrapper) => A)(implicit traceContext: TraceContext, tracer: Tracer): A
- Attributes
- protected
- Definition Classes
- Spanning
- def withSpanFromGrpcContext[A](description: String)(f: (TraceContext) => (SpanWrapper) => A)(implicit tracer: Tracer): A
- Attributes
- protected
- Definition Classes
- Spanning