dumper

Documentation

Index

• type ConnMetadata
• type Direction
  • func (d Direction) String() string
• type DumpValue
• type Dumper
• type HexDumper
  • func NewHexDumper() *HexDumper
  • func (h *HexDumper) Dump(in []byte, direction Direction, connMetadata *ConnMetadata, ...) error
  • func (h *HexDumper) Log(values []DumpValue)
  • func (h *HexDumper) Name() string
  • func (h *HexDumper) NewConnMetadata() *ConnMetadata
  • func (h *HexDumper) Read(in []byte, direction Direction, connMetadata *ConnMetadata) []DumpValue
• type MysqlDumper
  • func NewMysqlDumper() *MysqlDumper
  • func (m *MysqlDumper) Dump(in []byte, direction Direction, connMetadata *ConnMetadata, ...) error
  • func (m *MysqlDumper) Log(values []DumpValue)
  • func (m *MysqlDumper) Name() string
  • func (m *MysqlDumper) NewConnMetadata() *ConnMetadata
  • func (m *MysqlDumper) Read(in []byte, direction Direction, connMetadata *ConnMetadata) []DumpValue
• type PgDumper
  • func NewPgDumper() *PgDumper
  • func (p *PgDumper) Dump(in []byte, direction Direction, connMetadata *ConnMetadata, ...) error
  • func (p *PgDumper) Log(values []DumpValue)
  • func (p *PgDumper) Name() string
  • func (p *PgDumper) NewConnMetadata() *ConnMetadata
  • func (p *PgDumper) Read(in []byte, direction Direction, connMetadata *ConnMetadata) []DumpValue

Types

type ConnMetadata

type ConnMetadata struct {
	DumpValues []DumpValue
	Internal   interface{} // internal metadata for dumper
}

ConnMetadata is metadada per TCP connection

type Direction

type Direction int

Direction of TCP commnication

const (
	// ClientToRemote is client->proxy->remote
	ClientToRemote Direction = iota
	// RemoteToClient is client<-proxy<-remote
	RemoteToClient
	// SrcToDst is src->dst
	SrcToDst
	// DstToSrc is dst->src
	DstToSrc
	// Unknown direction
	Unknown Direction = 9
)

func (Direction) String

func (d Direction) String() string

type DumpValue

type DumpValue struct {
	Key   string
	Value interface{}
}

DumpValue ...

type Dumper

type Dumper interface {
	Name() string
	Dump(in []byte, direction Direction, connMetadata *ConnMetadata, additional []DumpValue) error
	Read(in []byte, direction Direction, connMetadata *ConnMetadata) []DumpValue
	Log(values []DumpValue)
	NewConnMetadata() *ConnMetadata
}

Dumper interface

type HexDumper

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

HexDumper ...

func NewHexDumper

func NewHexDumper() *HexDumper

NewHexDumper returns a HexDumper

func (*HexDumper) Dump

func (h *HexDumper) Dump(in []byte, direction Direction, connMetadata *ConnMetadata, additional []DumpValue) error

Dump TCP

func (*HexDumper) Log

func (h *HexDumper) Log(values []DumpValue)

Log values

func (*HexDumper) Name

func (h *HexDumper) Name() string

Name return dumper name

func (*HexDumper) NewConnMetadata

func (h *HexDumper) NewConnMetadata() *ConnMetadata

NewConnMetadata ...

func (*HexDumper) Read

func (h *HexDumper) Read(in []byte, direction Direction, connMetadata *ConnMetadata) []DumpValue

Read return byte to analyzed string

type MysqlDumper

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

MysqlDumper struct

func NewMysqlDumper

func NewMysqlDumper() *MysqlDumper

NewMysqlDumper returns a MysqlDumper

func (*MysqlDumper) Dump

func (m *MysqlDumper) Dump(in []byte, direction Direction, connMetadata *ConnMetadata, additional []DumpValue) error

Dump query of MySQL

func (*MysqlDumper) Log

func (m *MysqlDumper) Log(values []DumpValue)

Log values

func (*MysqlDumper) Name

func (m *MysqlDumper) Name() string

Name return dumper name

func (*MysqlDumper) NewConnMetadata

func (m *MysqlDumper) NewConnMetadata() *ConnMetadata

NewConnMetadata return metadata per TCP connection

func (*MysqlDumper) Read

func (m *MysqlDumper) Read(in []byte, direction Direction, connMetadata *ConnMetadata) []DumpValue

Read return byte to analyzed string

type PgDumper

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

PgDumper struct

func NewPgDumper

func NewPgDumper() *PgDumper

NewPgDumper returns a PgDumper

func (*PgDumper) Dump

func (p *PgDumper) Dump(in []byte, direction Direction, connMetadata *ConnMetadata, additional []DumpValue) error

Dump query of PostgreSQL

func (*PgDumper) Log

func (p *PgDumper) Log(values []DumpValue)

Log values

func (*PgDumper) Name

func (p *PgDumper) Name() string

Name return dumper name

func (*PgDumper) NewConnMetadata

func (p *PgDumper) NewConnMetadata() *ConnMetadata

NewConnMetadata ...

func (*PgDumper) Read

func (p *PgDumper) Read(in []byte, direction Direction, connMetadata *ConnMetadata) []DumpValue

Read return byte to analyzed string