proxy

type AuthClient struct {
	// contains filtered or unexported fields
}

type AuthServer struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type Conn struct {
	BrokerAddress   string
	LocalConnection net.Conn
}

type ConnSet struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type DeadlineReadWriteCloser interface {
	io.ReadWriteCloser
	SetWriteDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetDeadline(t time.Time) error
}

type DeadlineReader interface {
	io.Reader
	SetReadDeadline(t time.Time) error
}

type DeadlineReaderWriter interface {
	DeadlineReader
	DeadlineWriter
	SetDeadline(t time.Time) error
}

type DeadlineWriter interface {
	io.Writer
	SetWriteDeadline(t time.Time) error
}

type DefaultRequestHandler struct {
}

type DefaultResponseHandler struct {
}

type Dialer interface {
	Dial(network, addr string) (c net.Conn, err error)
}

type ListenFunc func(cfg config.ListenerConfig) (l net.Listener, err error)

type Listeners struct {
	// contains filtered or unexported fields
}

type LocalSasl struct {
	// contains filtered or unexported fields
}

type LocalSaslAuth interface {
	// contains filtered or unexported methods
}

type LocalSaslOauth struct {
	// contains filtered or unexported fields
}

type LocalSaslParams struct {
	// contains filtered or unexported fields
}

type LocalSaslPlain struct {
	// contains filtered or unexported fields
}

type ProcessorConfig struct {
	MaxOpenRequests       int
	NetAddressMappingFunc config.NetAddressMappingFunc
	RequestBufferSize     int
	ResponseBufferSize    int
	WriteTimeout          time.Duration
	ReadTimeout           time.Duration
	LocalSasl             *LocalSasl
	AuthServer            *AuthServer
	ForbiddenApiKeys      map[int16]struct{}
}

type RequestHandler interface {
	// contains filtered or unexported methods
}

type RequestsLoopContext struct {
	// contains filtered or unexported fields
}

type ResponseHandler interface {
	// contains filtered or unexported methods
}

type ResponsesLoopContext struct {
	// contains filtered or unexported fields
}

type SASLAuthByProxy interface {
	// contains filtered or unexported methods
}

type SASLHandshake struct {
	// contains filtered or unexported fields
}

type SASLOAuthBearerAuth struct {
	// contains filtered or unexported fields
}

type SASLPlainAuth struct {
	// contains filtered or unexported fields
}

type SaslAuthV0RequestHandler struct {
}

type SaslAuthV0ResponseHandler struct {
}

type SaslOAuthBearer struct{}

type TCPConnOptions struct {
	KeepAlive       time.Duration
	ReadBufferSize  int
	WriteBufferSize int
}