handshake

Documentation

Index

• Variables
• type BufferedConn
  • func VMInsertClient(c net.Conn, compressionLevel int) (*BufferedConn, error)
  • func VMInsertServer(c net.Conn, compressionLevel int) (*BufferedConn, error)
  • func VMSelectClient(c net.Conn, compressionLevel int) (*BufferedConn, error)
  • func VMSelectServer(c net.Conn, compressionLevel int) (*BufferedConn, error)
  • func (bc *BufferedConn) Close() error
  • func (bc *BufferedConn) Flush() error
  • func (bc *BufferedConn) Read(p []byte) (int, error)
  • func (bc *BufferedConn) SetDeadline(t time.Time) error
  • func (bc *BufferedConn) SetReadDeadline(t time.Time) error
  • func (bc *BufferedConn) SetWriteDeadline(t time.Time) error
  • func (bc *BufferedConn) Write(p []byte) (int, error)
• type Func

Variables

var ErrIgnoreHealthcheck = fmt.Errorf("TCP healthcheck - ignore it")

ErrIgnoreHealthcheck means the TCP healthckeck, which must be ignored.

The TCP healthcheck is performed by opening and then immediately closing the connection.

Types

type BufferedConn

type BufferedConn struct {
	net.Conn
	// contains filtered or unexported fields
}

BufferedConn is a net.Conn with Flush suport.

func VMInsertClient

func VMInsertClient(c net.Conn, compressionLevel int) (*BufferedConn, error)

VMInsertClient performs client-side handshake for vminsert protocol.

compressionLevel is the level used for compression of the data sent to the server. compressionLevel <= 0 means 'no compression'

func VMInsertServer

func VMInsertServer(c net.Conn, compressionLevel int) (*BufferedConn, error)

VMInsertServer performs server-side handshake for vminsert protocol.

compressionLevel is the level used for compression of the data sent to the client. compressionLevel <= 0 means 'no compression'

func VMSelectClient

func VMSelectClient(c net.Conn, compressionLevel int) (*BufferedConn, error)

VMSelectClient performs client-side handshake for vmselect protocol.

compressionLevel is the level used for compression of the data sent to the server. compressionLevel <= 0 means 'no compression'

func VMSelectServer

func VMSelectServer(c net.Conn, compressionLevel int) (*BufferedConn, error)

VMSelectServer performs server-side handshake for vmselect protocol.

compressionLevel is the level used for compression of the data sent to the client. compressionLevel <= 0 means 'no compression'

func (*BufferedConn) Close

func (bc *BufferedConn) Close() error

Close closes bc.

func (*BufferedConn) Flush

func (bc *BufferedConn) Flush() error

Flush flushes internal write buffers to the underlying conn.

func (*BufferedConn) Read

func (bc *BufferedConn) Read(p []byte) (int, error)

Read reads up to len(p) from bc to p.

func (*BufferedConn) SetDeadline

func (bc *BufferedConn) SetDeadline(t time.Time) error

SetDeadline sets read and write deadlines for bc to t.

Deadline is checked on each Read and Write call.

func (*BufferedConn) SetReadDeadline

func (bc *BufferedConn) SetReadDeadline(t time.Time) error

SetReadDeadline sets read deadline for bc to t.

Deadline is checked on each Read call.

func (*BufferedConn) SetWriteDeadline

func (bc *BufferedConn) SetWriteDeadline(t time.Time) error

SetWriteDeadline sets write deadline for bc to t.

Deadline is checked on each Write call.

func (*BufferedConn) Write

func (bc *BufferedConn) Write(p []byte) (int, error)

Write writes p to bc.

Do not forget to call Flush if needed.

type Func

type Func func(c net.Conn, compressionLevel int) (*BufferedConn, error)

Func must perform handshake on the given c using the given compressionLevel.

It must return BufferedConn wrapper for c on successful handshake.