redis

Documentation

Index

• Constants
• Variables
• type Redis
  • func (redis *Redis) ConnectionTimeout() time.Duration
  • func (redis *Redis) GapInStream(tcptuple *common.TcpTuple, dir uint8, nbytes int, private protos.ProtocolData) (priv protos.ProtocolData, drop bool)
  • func (redis *Redis) GetPorts() []int
  • func (redis *Redis) Init(test_mode bool, results publisher.Client) error
  • func (redis *Redis) InitDefaults()
  • func (redis *Redis) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple, dir uint8, ...) protos.ProtocolData
  • func (redis *Redis) ReceivedFin(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
• type RedisMessage
• type RedisStream
  • func (stream *RedisStream) PrepareForNewMessage()
• type RedisTransaction

Constants

const (
	START = iota
	BULK_ARRAY
	SIMPLE_MESSAGE
)

Variables

var RedisCommands = map[string]struct{}{}/* 158 elements not displayed */

Keep sorted for future command addition

Types

type Redis

type Redis struct {
	// config
	Ports         []int
	Send_request  bool
	Send_response bool
	// contains filtered or unexported fields
}

func (*Redis) ConnectionTimeout

func (redis *Redis) ConnectionTimeout() time.Duration

func (*Redis) GapInStream

func (redis *Redis) GapInStream(tcptuple *common.TcpTuple, dir uint8,
	nbytes int, private protos.ProtocolData) (priv protos.ProtocolData, drop bool)

func (*Redis) GetPorts

func (redis *Redis) GetPorts() []int

func (*Redis) Init

func (redis *Redis) Init(test_mode bool, results publisher.Client) error

func (*Redis) InitDefaults

func (redis *Redis) InitDefaults()

func (*Redis) Parse

func (redis *Redis) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple, dir uint8,
	private protos.ProtocolData) protos.ProtocolData

func (*Redis) ReceivedFin

func (redis *Redis) ReceivedFin(tcptuple *common.TcpTuple, dir uint8,
	private protos.ProtocolData) protos.ProtocolData

type RedisMessage

type RedisMessage struct {
	Ts            time.Time
	NumberOfBulks int64
	Bulks         []string

	TcpTuple     common.TcpTuple
	CmdlineTuple *common.CmdlineTuple
	Direction    uint8

	IsRequest bool
	IsError   bool
	Message   string
	Method    string
	Path      string
	Size      int
	// contains filtered or unexported fields
}

type RedisStream

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

func (*RedisStream) PrepareForNewMessage

func (stream *RedisStream) PrepareForNewMessage()

type RedisTransaction

type RedisTransaction struct {
	Type string

	Src          common.Endpoint
	Dst          common.Endpoint
	ResponseTime int32
	Ts           int64
	JsTs         time.Time

	Method   string
	Path     string
	Query    string
	IsError  bool
	BytesOut int
	BytesIn  int

	Redis common.MapStr

	Request_raw  string
	Response_raw string
	// contains filtered or unexported fields
}