protocol

Documentation

Index

• type Conn
  • func NewConn(rawConn net.Conn) *Conn
  • func (c *Conn) ReadPacket() (*Packet, error)
  • func (c *Conn) WriteFrame(outgoing *frame.Frame) error
• type Packet
  • func (p *Packet) Frame() *frame.Frame
  • func (p *Packet) FrameBody() *frame.Body
  • func (p *Packet) Header() *frame.Header
  • func (p *Packet) Raw() []byte

Types

type Conn

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

Conn represent incoming client connection or ongoing connection to cassandra server. Reading and Writing Frames/Packages needs to be done sequential because Conn implementation is not thread safe. Conn package is used to intercept and preform custom Cassandra handshake and in case of connection incoming connection to provide ability to audit incoming client packages.

func NewConn

func NewConn(rawConn net.Conn) *Conn

NewConn is used to create a new connection.

func (*Conn) ReadPacket

func (c *Conn) ReadPacket() (*Packet, error)

ReadPacket is used to read packet from the connection.

func (*Conn) WriteFrame

func (c *Conn) WriteFrame(outgoing *frame.Frame) error

WriteFrame is used to write frame to the connection.

type Packet

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

Packet represent cassandra packet frame with raw unparsed packet payload.

func (*Packet) Frame

func (p *Packet) Frame() *frame.Frame

Frame returns frame.

func (*Packet) FrameBody

func (p *Packet) FrameBody() *frame.Body

FrameBody returns frame body.

func (*Packet) Header

func (p *Packet) Header() *frame.Header

Header returns frame header.

func (*Packet) Raw

func (p *Packet) Raw() []byte

Raw returns raw packet payload.