proxy

Dec 1, 2018

Changes in this version

+ const SASLOAuthBearer

type LocalSasl

+ func NewLocalSasl(params LocalSaslParams) *LocalSasl

+ type LocalSaslAuth interface

+ type LocalSaslOauth struct

+ func NewLocalSaslOauth(tokenAuthenticator apis.TokenInfo) *LocalSaslOauth

+ type LocalSaslParams struct

+ type LocalSaslPlain struct

+ func NewLocalSaslPlain(localAuthenticator apis.PasswordAuthenticator) *LocalSaslPlain

+ type SASLAuthByProxy interface

+ type SASLHandshake struct

+ type SASLOAuthBearerAuth struct

+ type SaslOAuthBearer struct

+ func (p SaslOAuthBearer) GetClientInitialResponse(saslAuthBytes []byte) (token string, authzid string, extensions map[string]string, err error)

+ func (p SaslOAuthBearer) ToBytes(tokenValue string, authorizationId string, saslExtensions map[string]string) []byte

May 11, 2018

Changes in this version

+ type DefaultRequestHandler struct

+ type DefaultResponseHandler struct

+ type RequestHandler interface

+ type RequestsLoopContext struct

+ type ResponseHandler interface

+ type ResponsesLoopContext struct

+ type SaslAuthV0RequestHandler struct

+ type SaslAuthV0ResponseHandler struct

May 6, 2018

Changes in this version

+ type Dialer interface

+ Dial func(network, addr string) (c net.Conn, err error)

Mar 18, 2018

Changes in this version

+ type AuthClient struct

+ type AuthServer struct

type Client

+ func (c *Client) DialAndAuth(brokerAddress string, tlsConfig *tls.Config) (net.Conn, error)

type DeadlineReadWriteCloser

+ SetDeadline func(t time.Time) error

type DeadlineReaderWriter

+ SetDeadline func(t time.Time) error

+ type LocalSasl struct

type ProcessorConfig

+ AuthServer *AuthServer

+ LocalSasl *LocalSasl

Mar 2, 2018

Changes in this version

+ const SASLPlain

+ func NewCollector(connSet *ConnSet) prometheus.Collector

+ type Client struct

+ func NewClient(conns *ConnSet, c *config.Config, ...) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Dial(brokerAddress string, tlsConfig *tls.Config) (net.Conn, error)

+ func (c *Client) Run(connSrc <-chan Conn) error

+ type Conn struct

+ BrokerAddress string

+ LocalConnection net.Conn

+ type ConnSet struct

+ func NewConnSet() *ConnSet

+ func (c *ConnSet) Add(id string, conn net.Conn)

+ func (c *ConnSet) Close() error

+ func (c *ConnSet) Conns(ids ...string) []net.Conn

+ func (c *ConnSet) Count() map[string]int

+ func (c *ConnSet) IDs() []string

+ func (c *ConnSet) Remove(id string, conn net.Conn) error

+ func (c *ConnSet) String() string

+ type DeadlineReadWriteCloser interface

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

+ type DeadlineReader interface

+ SetReadDeadline func(t time.Time) error

+ type DeadlineReaderWriter interface

+ type DeadlineWriter interface

+ SetWriteDeadline func(t time.Time) error

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

+ type Listeners struct

+ func NewListeners(cfg *config.Config) (*Listeners, error)

+ func (p *Listeners) GetNetAddressMapping(brokerHost string, brokerPort int32) (listenerHost string, listenerPort int32, err error)

+ func (p *Listeners) ListenDynamicInstance(brokerAddress string) (string, int32, error)

+ func (p *Listeners) ListenInstances(cfgs []config.ListenerConfig) (<-chan Conn, error)

+ type ProcessorConfig struct

+ ForbiddenApiKeys map[int16]struct{}

+ ListenerAuth bool

+ ListenerAuthenticator shared.PasswordAuthenticator

+ MaxOpenRequests int

+ NetAddressMappingFunc config.NetAddressMappingFunc

+ ReadTimeout time.Duration

+ RequestBufferSize int

+ ResponseBufferSize int

+ WriteTimeout time.Duration

+ type SASLPlainAuth struct

+ type TCPConnOptions struct

+ KeepAlive time.Duration

+ ReadBufferSize int

+ WriteBufferSize int