shim

Documentation

Index

• type Conn
  • func (c *Conn) Close() error
  • func (c *Conn) LocalAddr() net.Addr
  • func (c *Conn) Read(b []byte) (int, error)
  • func (c *Conn) RemoteAddr() net.Addr
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) SetReadDeadline(t time.Time) error
  • func (c *Conn) SetWriteDeadline(t time.Time) error
  • func (c *Conn) Write(b []byte) (int, error)
• type Dialer
  • func NewDialer(cfg DialerConfig) *Dialer
  • func (d Dialer) Dial(network, addr string) (net.Conn, error)
  • func (d Dialer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)
• type DialerConfig
• type InvalidMessageTypeError
  • func (e InvalidMessageTypeError) Error() string
• type InvalidNetworkError
  • func (e InvalidNetworkError) Error() string

Types

type Conn

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

Implements net.Conn

Note: Only Kafka protocol messages can be read or written. This means no TLS handshake! This isn't a serious problem since the underlying WebSocket connection can provide TLS on its own

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) LocalAddr

func (c *Conn) LocalAddr() net.Addr

func (*Conn) Read

func (c *Conn) Read(b []byte) (int, error)

func (*Conn) RemoteAddr

func (c *Conn) RemoteAddr() net.Addr

func (*Conn) SetDeadline

func (c *Conn) SetDeadline(t time.Time) error

func (*Conn) SetReadDeadline

func (c *Conn) SetReadDeadline(t time.Time) error

func (*Conn) SetWriteDeadline

func (c *Conn) SetWriteDeadline(t time.Time) error

func (*Conn) Write

func (c *Conn) Write(b []byte) (int, error)

type Dialer

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

Implements proxy.Dialer and proxy.ContextDialer

func NewDialer

func NewDialer(cfg DialerConfig) *Dialer

func (Dialer) Dial

func (d Dialer) Dial(network, addr string) (net.Conn, error)

func (Dialer) DialContext

func (d Dialer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)

type DialerConfig

type DialerConfig struct {
	TLS bool
}

type InvalidMessageTypeError

type InvalidMessageTypeError int

func (InvalidMessageTypeError) Error

func (e InvalidMessageTypeError) Error() string

type InvalidNetworkError

type InvalidNetworkError string

func (InvalidNetworkError) Error

func (e InvalidNetworkError) Error() string