CallLoggingNodeExtension

class CallLoggingNodeExtension(logger: Logger, levels: CallLoggingNodeExtension.LoggingLevels) : RPCNodeExtension

Types

Direction
Link copied to clipboard
enum Direction : Enum<CallLoggingNodeExtension.Direction>
Factory
Link copied to clipboard
class Factory(logger: Logger, levels: CallLoggingNodeExtension.LoggingLevels) : RPCNodeExtension.Factory<CallLoggingNodeExtension>
Identifier
Link copied to clipboard
LoggingLevels
Link copied to clipboard
data class LoggingLevels(bind: LoggingLevel, callOpen: LoggingLevel, callResponse: LoggingLevel, callError: LoggingLevel, streamStart: LoggingLevel, streamItem: LoggingLevel, streamEnd: LoggingLevel, streamError: LoggingLevel)

Functions

bind
Link copied to clipboard
open suspend override fun bind(transport: RPCTransport, contract: RPCNode.Contract)
Binds an extension to a transport.
enhanceParallelWorkContext
Link copied to clipboard
open suspend fun enhanceParallelWorkContext(context: CoroutineContext): CoroutineContext
interceptIncomingBistreamCall
Link copied to clipboard
open suspend override fun <PAYLOAD, CLIENT_STREAM, SERVER_STREAM> interceptIncomingBistreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: RunnableCallDescription.ColdBistream<PAYLOAD, CLIENT_STREAM, SERVER_STREAM>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>
interceptIncomingDownstreamCall
Link copied to clipboard
open suspend override fun <PAYLOAD, SERVER_STREAM> interceptIncomingDownstreamCall(payload: PAYLOAD, call: RunnableCallDescription.ColdDownstream<PAYLOAD, SERVER_STREAM>, next: suspend (PAYLOAD) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>
interceptIncomingSingleCall
Link copied to clipboard
open suspend override fun <PAYLOAD, RESPONSE> interceptIncomingSingleCall(payload: PAYLOAD, call: RunnableCallDescription.Single<PAYLOAD, RESPONSE>, next: suspend (PAYLOAD) -> RESPONSE): RESPONSE
interceptIncomingUpstreamCall
Link copied to clipboard
open suspend override fun <PAYLOAD, CLIENT_STREAM, RESPONSE> interceptIncomingUpstreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: RunnableCallDescription.ColdUpstream<PAYLOAD, CLIENT_STREAM, RESPONSE>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> RESPONSE): RESPONSE
interceptOutgoingBistreamCall
Link copied to clipboard
open suspend override fun <PAYLOAD, CLIENT_STREAM, SERVER_STREAM> interceptOutgoingBistreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: ColdBistreamCallDescription<PAYLOAD, CLIENT_STREAM, SERVER_STREAM>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>
interceptOutgoingDownstreamCall
Link copied to clipboard
open suspend override fun <PAYLOAD, SERVER_STREAM> interceptOutgoingDownstreamCall(payload: PAYLOAD, call: ColdDownstreamCallDescription<PAYLOAD, SERVER_STREAM>, next: suspend (PAYLOAD) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>
interceptOutgoingSingleCall
Link copied to clipboard
open suspend override fun <PAYLOAD, RESPONSE> interceptOutgoingSingleCall(payload: PAYLOAD, call: SingleCallDescription<PAYLOAD, RESPONSE>, next: suspend (PAYLOAD) -> RESPONSE): RESPONSE
interceptOutgoingUpstreamCall
Link copied to clipboard
open suspend override fun <PAYLOAD, CLIENT_STREAM, RESPONSE> interceptOutgoingUpstreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: ColdUpstreamCallDescription<PAYLOAD, CLIENT_STREAM, RESPONSE>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> RESPONSE): RESPONSE
whileConnected
Link copied to clipboard
open suspend fun whileConnected()

Properties

providedServices
Link copied to clipboard
open val providedServices: List<ServiceDescription>