default | /src/network/connection.ts | kafkasaur@v0.0.7

class default

import { default } from "https://deno.land/x/kafkasaur@v0.0.7/src/network/connection.ts";

Constructors

new

default(unnamed 0: ConnectionOptions)

authExpectResponse: boolean

authHandlers: any

broker: string

bytesBuffered: number

bytesNeeded: number

chunks: Buffer[] | Uint8Array[]

clientId: string

readonly

connected

connectionStatus: string

connectionTimeout: number

correlationId: number

host: string

logDebug: any

logError: any

logger: Logger

port: number

rack: string | null

requestQueue: RequestQueue

requestTimeout: number

sasl: Record<string, unknown> | null

shouldLogBuffers: any

shouldLogFetchBuffer: any

socket: any

socketFactory: ISocketFactory

ssl: Record<string, unknown> | null

authenticate(unnamed 0: any)

processData(rd: Uint8Array | Buffer)

send(unnamed 0: any)