memcache

Documentation

Index

• Variables
• func L7RuleParser(rule *cilium.PortNetworkPolicyRule) []proxylib.L7NetworkPolicyRule
• type Parser
  • func (p *Parser) OnData(reply, endStream bool, dataBuffers [][]byte) (proxylib.OpType, int)
• type ParserFactory
  • func (p *ParserFactory) Create(connection *proxylib.Connection) interface{}
• type Rule
  • func (rule *Rule) Matches(data interface{}) bool

Variables

var MemcacheOpCodeMap = map[string]memcacheCommandSet{
	"add": {
		// contains filtered or unexported fields
	},
	"set": {
		// contains filtered or unexported fields
	},
	"replace": {
		// contains filtered or unexported fields
	},
	"append": {
		// contains filtered or unexported fields
	},
	"prepend": {
		// contains filtered or unexported fields
	},
	"cas": {
		// contains filtered or unexported fields
	},
	"incr": {
		// contains filtered or unexported fields
	},
	"decr": {
		// contains filtered or unexported fields
	},
	"storage": {
		// contains filtered or unexported fields
	},

	"get": {
		// contains filtered or unexported fields
	},

	"delete": {
		// contains filtered or unexported fields
	},

	"touch": {
		// contains filtered or unexported fields
	},

	"gat": {
		// contains filtered or unexported fields
	},

	"writeGroup": {
		// contains filtered or unexported fields
	},

	"slabs": {
		// contains filtered or unexported fields
	},

	"lru": {
		// contains filtered or unexported fields
	},

	"lru_crawler": {
		// contains filtered or unexported fields
	},

	"watch": {
		// contains filtered or unexported fields
	},

	"stats": {
		// contains filtered or unexported fields
	},

	"flush_all": {
		// contains filtered or unexported fields
	},

	"cache_memlimit": {
		// contains filtered or unexported fields
	},

	"version": {
		// contains filtered or unexported fields
	},

	"misbehave": {
		// contains filtered or unexported fields
	},

	"quit": {
		// contains filtered or unexported fields
	},

	"noop": {
		// contains filtered or unexported fields
	},
	"verbosity": {
		// contains filtered or unexported fields
	},
	"sasl-list-mechs": {
		// contains filtered or unexported fields
	},
	"sasl-auth": {
		// contains filtered or unexported fields
	},
	"sasl-step": {
		// contains filtered or unexported fields
	},
	"rget": {
		// contains filtered or unexported fields
	},
	"rset": {
		// contains filtered or unexported fields
	},
	"rsetq": {
		// contains filtered or unexported fields
	},
	"rappend": {
		// contains filtered or unexported fields
	},
	"rappendq": {
		// contains filtered or unexported fields
	},
	"rprepend": {
		// contains filtered or unexported fields
	},
	"rprependq": {
		// contains filtered or unexported fields
	},
	"rdelete": {
		// contains filtered or unexported fields
	},
	"rdeleteq": {
		// contains filtered or unexported fields
	},
	"rincr": {
		// contains filtered or unexported fields
	},
	"rincrq": {
		// contains filtered or unexported fields
	},
	"rdecr": {
		// contains filtered or unexported fields
	},
	"rdecrq": {
		// contains filtered or unexported fields
	},
	"set-vbucket": {
		// contains filtered or unexported fields
	},
	"get-vbucket": {
		// contains filtered or unexported fields
	},
	"del-vbucket": {
		// contains filtered or unexported fields
	},
	"tap-connect": {
		// contains filtered or unexported fields
	},
	"tap-mutation": {
		// contains filtered or unexported fields
	},
	"tap-delete": {
		// contains filtered or unexported fields
	},
	"tap-flush": {
		// contains filtered or unexported fields
	},
	"tap-opaque": {
		// contains filtered or unexported fields
	},
	"tap-vbucket-set": {
		// contains filtered or unexported fields
	},
	"tap-checkpoint-start": {
		// contains filtered or unexported fields
	},
	"tap-checkpoint-end": {
		// contains filtered or unexported fields
	},
}

MemcacheOpCodeMap maps operation names and groups used in policy rules to sets of operation names and opcodes that are allowed in such a policy rule. for more information on protocol check https://github.com/memcached/memcached/wiki/Protocols

Functions

func L7RuleParser

func L7RuleParser(rule *cilium.PortNetworkPolicyRule) []proxylib.L7NetworkPolicyRule

L7RuleParser parses protobuf L7 rules to and array of Rule May panic

Types

type Parser

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

Parser implements proxylib.Parser

func (*Parser) OnData

func (p *Parser) OnData(reply, endStream bool, dataBuffers [][]byte) (proxylib.OpType, int)

OnData parses memcached data

type ParserFactory

type ParserFactory struct{}

ParserFactory implements proxylib.ParserFactory

func (*ParserFactory) Create

func (p *ParserFactory) Create(connection *proxylib.Connection) interface{}

Create creates memcached parser

type Rule

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

Rule matches against memcached requests

func (*Rule) Matches

func (rule *Rule) Matches(data interface{}) bool

Matches returns true if the Rule matches