proxy

Documentation

Index

• Constants
• Variables
• func NewCollector(connSet *ConnSet) prometheus.Collector
• type AuthClient
• type AuthServer
• type Client
  • func NewClient(conns *ConnSet, c *config.Config, ...) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) DialAndAuth(brokerAddress string) (net.Conn, error)
  • func (c *Client) Run(connSrc <-chan Conn) error
• type Conn
• type ConnSet
  • 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
• type DeadlineReader
• type DeadlineReaderWriter
• type DeadlineWriter
• type DefaultRequestHandler
• type DefaultResponseHandler
• type Dialer
• type ListenFunc
• type Listeners
  • 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 LocalSasl
  • func NewLocalSasl(params LocalSaslParams) *LocalSasl
• type LocalSaslAuth
• type LocalSaslOauth
  • func NewLocalSaslOauth(tokenAuthenticator apis.TokenInfo) *LocalSaslOauth
• type LocalSaslParams
• type LocalSaslPlain
  • func NewLocalSaslPlain(localAuthenticator apis.PasswordAuthenticator) *LocalSaslPlain
• type ProcessorConfig
• type RequestHandler
• type RequestsLoopContext
• type ResponseHandler
• type ResponsesLoopContext
• type SASLAuthByProxy
• type SASLHandshake
• type SASLOAuthBearerAuth
• type SASLPlainAuth
• type SASLSCRAMAuth
• type SaslAuthV0RequestHandler
• type SaslAuthV0ResponseHandler
• type SaslOAuthBearer
  • 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
• type TCPConnOptions

Constants

const (
	SASLPlain       = "PLAIN"
	SASLOAuthBearer = "OAUTHBEARER"
	SASLSCRAM256    = "SCRAM-SHA-256"
	SASLSCRAM512    = "SCRAM-SHA-512"
)

Variables

var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }

Workaround for xdg-go not having accepted this pull request: https://github.com/xdg-go/scram/pull/1/commits

var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }

Functions

func NewCollector

func NewCollector(connSet *ConnSet) prometheus.Collector

Types

type AuthClient

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

type AuthServer

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

type Client

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

Client is a type to handle connecting to a Server. All fields are required unless otherwise specified.

func NewClient

func NewClient(conns *ConnSet, c *config.Config, netAddressMappingFunc config.NetAddressMappingFunc, localPasswordAuthenticator apis.PasswordAuthenticator, localTokenAuthenticator apis.TokenInfo, saslTokenProvider apis.TokenProvider, gatewayTokenProvider apis.TokenProvider, gatewayTokenInfo apis.TokenInfo) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) DialAndAuth

func (c *Client) DialAndAuth(brokerAddress string) (net.Conn, error)

func (*Client) Run

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

Run causes the client to start waiting for new connections to connSrc and proxy them to the destination instance. It blocks until connSrc is closed.

type Conn

type Conn struct {
	BrokerAddress   string
	LocalConnection net.Conn
}

Conn represents a connection from a client to a specific instance.

type ConnSet

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

A ConnSet tracks net.Conns associated with a provided ID.

func NewConnSet

func NewConnSet() *ConnSet

NewConnSet initializes a new ConnSet and returns it.

func (*ConnSet) Add

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

Add saves the provided conn and associates it with the given string identifier.

func (*ConnSet) Close

func (c *ConnSet) Close() error

Close closes every net.Conn contained in the set.

func (*ConnSet) Conns

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

Conns returns all active connections associated with the provided ids.

func (*ConnSet) Count

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

Count returns number of connection pro identifier

func (*ConnSet) IDs

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

IDs returns a slice of all identifiers which still have active connections.

func (*ConnSet) Remove

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

Remove undoes an Add operation to have the set forget about a conn. Do not Remove an id/conn pair more than it has been Added.

func (*ConnSet) String

func (c *ConnSet) String() string

String returns a debug string for the ConnSet.

type DeadlineReadWriteCloser

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

type DeadlineReader

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

type DeadlineReaderWriter

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

type DeadlineWriter

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

type DefaultRequestHandler

type DefaultRequestHandler struct {
}

type DefaultResponseHandler

type DefaultResponseHandler struct {
}

type Dialer

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

type ListenFunc

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

type Listeners

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

func NewListeners

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

func (*Listeners) GetNetAddressMapping

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

func (*Listeners) ListenDynamicInstance

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

func (*Listeners) ListenInstances

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

type LocalSasl

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

func NewLocalSasl

func NewLocalSasl(params LocalSaslParams) *LocalSasl

type LocalSaslAuth

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

type LocalSaslOauth

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

func NewLocalSaslOauth

func NewLocalSaslOauth(tokenAuthenticator apis.TokenInfo) *LocalSaslOauth

type LocalSaslParams

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

type LocalSaslPlain

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

func NewLocalSaslPlain

func NewLocalSaslPlain(localAuthenticator apis.PasswordAuthenticator) *LocalSaslPlain

type ProcessorConfig

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{}
	ProducerAcks0Disabled bool
}

type RequestHandler

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

type RequestsLoopContext

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

type ResponseHandler

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

type ResponsesLoopContext

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

type SASLAuthByProxy

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

type SASLHandshake

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

type SASLOAuthBearerAuth

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

type SASLPlainAuth

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

type SASLSCRAMAuth

type SASLSCRAMAuth struct {

	// authz id used for SASL/SCRAM authentication
	SCRAMAuthzID string
	// contains filtered or unexported fields
}

type SaslAuthV0RequestHandler

type SaslAuthV0RequestHandler struct {
}

type SaslAuthV0ResponseHandler

type SaslAuthV0ResponseHandler struct {
}

type SaslOAuthBearer

type SaslOAuthBearer struct{}

func (SaslOAuthBearer) GetClientInitialResponse

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

func (SaslOAuthBearer) ToBytes

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

type TCPConnOptions

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