memcache

Documentation

Index

• Constants
• Variables
• type Memcache
  • func (mc *Memcache) GapInStream(tcptuple *common.TcpTuple, dir uint8, nbytes int, private protos.ProtocolData) (priv protos.ProtocolData, drop bool)
  • func (mc *Memcache) GetPorts() []int
  • func (mc *Memcache) Init(testMode bool, results chan common.MapStr) error
  • func (mc *Memcache) InitDefaults()
  • func (mc *Memcache) InitWithConfig(config config.Memcache, testMode bool, results chan common.MapStr) error
  • func (mc *Memcache) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple, dir uint8, ...) protos.ProtocolData
  • func (mc *Memcache) ParseUdp(pkt *protos.Packet)
  • func (mc *Memcache) ReceivedFin(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
• type MemcacheHandler

Constants

const (
	MemcacheMagicRequest  = 0x80
	MemcacheMagicResponse = 0x81
)

const (
	MemcacheUnknownType commandTypeCode = iota
	MemcacheLoadMsg
	MemcacheStoreMsg
	MemcacheDeleteMsg
	MemcacheCounterMsg
	MemcacheInfoMsg
	MemcacheSlabCtrlMsg
	MemcacheLruCrawlerMsg
	MemcacheStatsMsg
	MemcacheSuccessResp
	MemcacheFailResp
	MemcacheAuthMsg
)

const (
	MemcacheCmdUNKNOWN commandCode = iota
	MemcacheCmdNoOp
	MemcacheCmdSet
	MemcacheCmdAdd
	MemcacheCmdReplace
	MemcacheCmdAppend
	MemcacheCmdPrepend
	MemcacheCmdCas

	MemcacheCmdGet
	MemcacheCmdGets

	MemcacheCmdIncr
	MemcacheCmdDecr
	MemcacheResCounterOp

	MemcacheCmdTouch

	MemcacheCmdDelete

	MemcacheCmdSlabs
	MemcacheCmdSlabsReassign
	MemcacheCmdSlabsAutomove

	MemcacheCmdLru
	MemcacheCmdLruEnable
	MemcacheCmdLruDisable
	MemcacheCmdLruSleep
	MemcacheCmdLruToCrawl
	MemcacheCmdLruCrawl

	MemcacheCmdStats
	MemcacheResStat

	MemcacheCmdFlushAll
	MemcacheCmdVerbosity
	MemcacheCmdQuit
	MemcacheCmdVersion

	MemcacheCmdSaslList
	MemcacheCmdSaslAuth
	MemcacheCmdSaslStep

	MemcacheResOK
	MemcacheResValue
	MemcacheResEnd

	MemcacheResStored
	MemcacheResNotStored
	MemcacheResExists
	MemcacheResNotFound

	MemcacheResTouched

	MemcacheResDeleted

	MemcacheErrError
	MemcacheErrClientError
	MemcacheErrServerError
	MemcacheErrBusy
	MemcacheErrBadClass
	MemcacheErrNoSpare
	MemcacheErrNotFull
	MemcacheErrUnsafe
	MemcacheErrSame

	MemcacheResVersion
)

Variables

var (
	ErrParserCaughtInError  = errors.New("memcache parser caught in error loop")
	ErrParserUnknownCommand = errors.New("unknown memcache command found")
	ErrNoMoreArgument       = errors.New("no more command arguments")
	ErrExpectedNumber       = errors.New("expected number value")
	ErrExpectedNoReply      = errors.New("expected noreply in argument list")
	ErrExpectedCRLF         = errors.New("expected CRLF")
	ErrExpectedKeys         = errors.New("message has no keys")
)

memcache text parser errors

var (
	ErrInvalidMemcacheMagic = errors.New("invalid memcache magic number")
	ErrLen                  = errors.New("length field error")
)

memcache binary parser errors

var (
	ErrInvalidMessage             = errors.New("message is invalid")
	ErrMixOfBinaryAndText         = errors.New("mix of binary and text in one connection")
	ErrResponseUnknownTransaction = errors.New("response from unknown transaction")
	ErrExpectedValueForMerge      = errors.New("expected value to merge with")
	ErrExpectedStatsForMerge      = errors.New("expected stat respose to merge with")
)

memcache transaction/message errors

var (
	NoteRequestPacketLoss    = "Packet loss while capturing the request"
	NoteResponsePacketLoss   = "Packet loss while capturing the response"
	NoteTransactionNoRequ    = "Invalid transaction. Request missing"
	NoteNonQuietResponseOnly = "Missing response for non-quiet request"
	NoteTransUnfinished      = "Unfinished transaction"
)

internal notes to be published with transaction

var (
	ErrNotImplemented = errors.New("not implemented")
)

var (
	ErrUdpIncompleteMessage = errors.New("attempt to parse incomplete message failed")
)

memcache UDP errors

Types

type Memcache

type Memcache struct {
	Ports protos.PortsConfig
	// contains filtered or unexported fields
}

memcache types

func (*Memcache) GapInStream

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

Called when a packets are missing from the tcp stream.

func (*Memcache) GetPorts

func (mc *Memcache) GetPorts() []int

Called to return the configured ports

func (*Memcache) Init

func (mc *Memcache) Init(testMode bool, results chan common.MapStr) error

Called to initialize the Plugin

func (*Memcache) InitDefaults

func (mc *Memcache) InitDefaults()

func (*Memcache) InitWithConfig

func (mc *Memcache) InitWithConfig(
	config config.Memcache,
	testMode bool,
	results chan common.MapStr,
) error

func (*Memcache) Parse

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

Called when payload data is available for parsing.

func (*Memcache) ParseUdp

func (mc *Memcache) ParseUdp(pkt *protos.Packet)

func (*Memcache) ReceivedFin

func (mc *Memcache) ReceivedFin(
	tcptuple *common.TcpTuple,
	dir uint8,
	private protos.ProtocolData,
) protos.ProtocolData

Called when the FIN flag is seen in the TCP stream.

type MemcacheHandler

type MemcacheHandler interface {
	// contains filtered or unexported methods
}