io.opencensus.proto.agent.trace.v1.trace_service
TraceServiceClient
Companion object TraceServiceClient
trait TraceServiceClient extends TraceService with TraceServiceClientPowerApi with AkkaGrpcClient
- Annotations
- @AkkaGrpcGenerated()
- Source
- TraceServiceClient.scala
- Alphabetic
- By Inheritance
- TraceServiceClient
- AkkaGrpcClient
- TraceServiceClientPowerApi
- TraceService
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def close(): Future[Done]
- Definition Classes
- AkkaGrpcClient
- abstract def closed: Future[Done]
- Definition Classes
- AkkaGrpcClient
- abstract def config(in: Source[CurrentLibraryConfig, NotUsed]): Source[UpdatedLibraryConfig, NotUsed]
After initialization, this RPC must be kept alive for the entire life of the application.
After initialization, this RPC must be kept alive for the entire life of the application. The agent pushes configs down to applications via a stream.
- Definition Classes
- TraceService
- abstract def export(in: Source[ExportTraceServiceRequest, NotUsed]): Source[ExportTraceServiceResponse, NotUsed]
For performance reasons, it is recommended to keep this RPC alive for the entire life of the application.
For performance reasons, it is recommended to keep this RPC alive for the entire life of the application.
- Definition Classes
- TraceService
Concrete 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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def config(): StreamResponseRequestBuilder[Source[CurrentLibraryConfig, NotUsed], UpdatedLibraryConfig]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer config(akka.stream.scaladsl.Source[io.opencensus.proto.agent.trace.v1.trace_service.CurrentLibraryConfig, akka.NotUsed]) if possible.
- Definition Classes
- TraceServiceClientPowerApi
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def export(): StreamResponseRequestBuilder[Source[ExportTraceServiceRequest, NotUsed], ExportTraceServiceResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer
export(akka.stream.scaladsl.Source[io.opencensus.proto.agent.trace.v1.trace_service.ExportTraceServiceRequest, akka.NotUsed]) if possible.- Definition Classes
- TraceServiceClientPowerApi
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()