proxy

Documentation

Index

• Constants
• func NewCollector(connSet *ConnSet) prometheus.Collector
• type Client
  • 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
• 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 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 ProcessorConfig
• type SASLPlainAuth
• type TCPConnOptions

Constants

const (
	SASLPlain = "PLAIN"
)

Functions

func NewCollector

func NewCollector(connSet *ConnSet) prometheus.Collector

Types

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 shared.PasswordAuthenticator) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) Dial

func (c *Client) Dial(brokerAddress string, tlsConfig *tls.Config) (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
}

type DeadlineReader

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

type DeadlineReaderWriter

type DeadlineReaderWriter interface {
	DeadlineReader
	DeadlineWriter
}

type DeadlineWriter

type DeadlineWriter interface {
	io.Writer
	SetWriteDeadline(t time.Time) 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 ProcessorConfig

type ProcessorConfig struct {
	MaxOpenRequests       int
	NetAddressMappingFunc config.NetAddressMappingFunc
	RequestBufferSize     int
	ResponseBufferSize    int
	WriteTimeout          time.Duration
	ReadTimeout           time.Duration
	ListenerAuth          bool
	ListenerAuthenticator shared.PasswordAuthenticator
	ForbiddenApiKeys      map[int16]struct{}
}

type SASLPlainAuth

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

type TCPConnOptions

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