proxy

Documentation

Index

• Constants
• 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
• type ProcessorConfig
• type RequestHandler
• type RequestsLoopContext
• type ResponseHandler
• type ResponsesLoopContext
• type SASLPlainAuth
• type SaslAuthV0RequestHandler
• type SaslAuthV0ResponseHandler
• type TCPConnOptions

Constants

const (
	SASLPlain = "PLAIN"
)

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, passwordAuthenticator apis.PasswordAuthenticator, tokenProvider apis.TokenProvider, tokenInfo 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
}

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

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 SASLPlainAuth

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

type SaslAuthV0RequestHandler

type SaslAuthV0RequestHandler struct {
}

type SaslAuthV0ResponseHandler

type SaslAuthV0ResponseHandler struct {
}

type TCPConnOptions

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