SocketProtobufOutputConsumer

class SocketProtobufOutputConsumer(dataChannel: SocketDataChannel, clock: Clock, val bufferByteSizeThresholdForFlush: Int, val additionalProperties: Map<String, String>) : OutputConsumer(source)

Constructors

constructor(dataChannel: SocketDataChannel, clock: Clock, bufferByteSizeThresholdForFlush: Int, additionalProperties: Map<String, String>)

fun accept(analytics: AirbyteAnalyticsTraceMessage)

fun accept(catalog: AirbyteCatalog)

fun accept(status: AirbyteConnectionStatus)

fun accept(error: AirbyteErrorTraceMessage)

fun accept(estimate: AirbyteEstimateTraceMessage)

fun accept(log: AirbyteLogMessage)

open fun accept(record: AirbyteRecordMessage)

fun accept(state: AirbyteStateMessage)

fun accept(streamStatus: AirbyteStreamStatusTraceMessage)

fun accept(trace: AirbyteTraceMessage)

fun accept(spec: ConnectorSpecification)

fun accept(destinationCatalog: DestinationCatalog)

open override fun accept(airbyteMessage: AirbyteMessage)

fun accept(airbyteProtoMessage: AirbyteMessage.AirbyteMessageProtobuf)

open fun andThen(after: Consumer<in AirbyteMessage?>?): Consumer<AirbyteMessage?>?

open override fun close()