redis

Documentation

Index

• Variables
• func NewDissector() api.Dissector
• type ConnectError
  • func (e *ConnectError) Error() string
• type RedisCommand
• type RedisInputStream
• type RedisKeyword
• type RedisPacket
• type RedisPayload
  • func (h RedisPayload) MarshalJSON() ([]byte, error)
• type RedisPayloader
• type RedisProtocol
  • func NewProtocol(is *RedisInputStream) *RedisProtocol
  • func (p *RedisProtocol) Read() (packet *RedisPacket, err error)
• type RedisType
• type RedisWrapper

Variables

var Dissector dissecting

Functions

func NewDissector

func NewDissector() api.Dissector

Types

type ConnectError

type ConnectError struct {
	Message string
}

ConnectError redis connection error,such as io timeout

func (*ConnectError) Error

func (e *ConnectError) Error() string

type RedisCommand

type RedisCommand string

type RedisInputStream

type RedisInputStream struct {
	*bufio.Reader
	Buf []byte
	// contains filtered or unexported fields
}

receive message from redis

type RedisKeyword

type RedisKeyword string

type RedisPacket

type RedisPacket struct {
	Type    RedisType    `json:"type"`
	Command RedisCommand `json:"command"`
	Key     string       `json:"key"`
	Value   string       `json:"value"`
	Keyword RedisKeyword `json:"keyword"`
}

type RedisPayload

type RedisPayload struct {
	Data interface{}
}

func (RedisPayload) MarshalJSON

func (h RedisPayload) MarshalJSON() ([]byte, error)

type RedisPayloader

type RedisPayloader interface {
	MarshalJSON() ([]byte, error)
}

type RedisProtocol

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

func NewProtocol

func NewProtocol(is *RedisInputStream) *RedisProtocol

func (*RedisProtocol) Read

func (p *RedisProtocol) Read() (packet *RedisPacket, err error)

type RedisType

type RedisType string

type RedisWrapper

type RedisWrapper struct {
	Method  string      `json:"method"`
	Url     string      `json:"url"`
	Details interface{} `json:"details"`
}