gomemcached

package module

Go to main page

Versions in this module

v0

v0.3.1

Mar 13, 2024

Changes in this version

type MCResponse

+ func (res *MCResponse) ReceiveWithDatapool(r io.Reader, hdrbytes []byte, getter func(uint64) ([]byte, error), ...) (n int, err error)

+ func (res *MCResponse) Recycle()

v0.3.0

Nov 13, 2023

Changes in this version

+ const BUCKET_DATA_SIZE_TOO_BIG

+ const BUCKET_DISK_SPACE_TOO_LOW

+ const BUCKET_RESIDENT_RATIO_TOO_LOW

+ const DatatypeFlagCompressed

+ const DatatypeFlagJSON

+ const DatatypeFlagXattrs

+ const ErrorMapCB50

+ const ErrorMapCB75

+ const ErrorMapInvalidVersion

+ const GET_ERROR_MAP

+ const SET_BUCKET_THROTTLE_PROPERTIES

+ const SET_NODE_THROTTLE_PROPERTIES

+ const SUBDOC_COUNTER

+ type ErrorMapVersion uint16

v0.2.1

Nov 2, 2022

Changes in this version

+ const BUCKET_SIZE_LIMIT_EXCEEDED

+ const CANCEL_RANGE_SCAN

+ const CONFIG_ONLY

+ const CONTINUE_RANGE_SCAN

+ const CREATE_RANGE_SCAN

+ const ComputeUnitsRead

+ const ComputeUnitsWrite

+ const GET_RANDOM_KEY

+ const RANGE_SCAN_COMPLETE

+ const RANGE_SCAN_MORE

+ const RATE_LIMITED_MAX_COMMANDS

+ const RATE_LIMITED_MAX_CONNECTIONS

+ const RATE_LIMITED_NETWORK_EGRESS

+ const RATE_LIMITED_NETWORK_INGRESS

+ const SCOPE_SIZE_LIMIT_EXCEEDED

+ const SET_BUCKET_COMPUTE_UNIT_THROTTLE_LIMITS

+ const SET_BUCKET_DATA_LIMIT_EXCEEDED

+ const WOULD_THROTTLE

+ var StatusDesc map[Status]string

+ func IsTenantLimit(e error) bool

type MCRequest

+ func (req *MCRequest) BytesPreallocated(out []byte)

type MCResponse

+ FlexibleExtras []byte

+ func (res *MCResponse) ComputeUnits() (ru uint64, wu uint64)

v0.1.4

Sep 30, 2021

Changes in this version

+ const DURABILITY_IMPOSSIBLE

+ const DURABILITY_INVALID_LEVEL

+ const GET_REPLICA

+ const SYNC_WRITE_RECOMMITINPROGRESS

type FrameObjType

+ const FramePreserveExpiry

v0.1.3

Apr 16, 2021

Changes in this version

+ const ADD_WITH_META

+ const DELETE_WITH_META

+ const FAST_FRAME_LEN

+ const SET_TIME_SYNC

+ const SET_WITH_META

+ const SUBDOC_DELETE

+ const SUBDOC_DICT_UPSERT

+ const SUBDOC_FLAG_ACCESS_DELETED

+ const SUBDOC_FLAG_ADD

+ const SUBDOC_FLAG_CREATE_AS_DELETED

+ const SUBDOC_FLAG_EXPAND_MACRRO_PATH

+ const SUBDOC_FLAG_MKDIR_PATH

+ const SUBDOC_FLAG_MKDOC

+ const SUBDOC_FLAG_NONE

+ const SUBDOC_FLAG_NONE_PATH

+ const SUBDOC_FLAG_REVIVED_DOC

+ const SUBDOC_FLAG_XATTR_PATH

+ const SUBDOC_MULTI_MUTATION

+ const SUBDOC_SUCCESS_DELETED

+ const XATTR_EINVAL

v0.1.2

Feb 5, 2021

Changes in this version

+ const FAST_USER_LEN

+ const MAX_USER_LEN

type FrameObjType

+ const FrameImpersonate

type MCRequest

+ UserLen int

+ Username [MAX_USER_LEN]byte

v0.1.1

Nov 9, 2020

Changes in this version

+ const DCP_OSO_SNAPSHOT

+ const UNKNOWN_STATUS

v0.1.0

May 11, 2020

Changes in this version

+ const ADD

+ const ADDQ

+ const APPEND

+ const APPENDQ

+ const AUDIT

+ const AUTH_CONTINUE

+ const AUTH_ERROR

+ const AUTH_STALE

+ const BACKFILL

+ const CHECKPOINT

+ const COLLECTIONS_GET_CID

+ const DCP_SEQNO_ADV

+ const DCP_SYSTEM_EVENT

+ const DECREMENT

+ const DECREMENTQ

+ const DELETE

+ const DELETEQ

+ const DELTA_BADVAL

+ const DUMP

+ const E2BIG

+ const EACCESS

+ const EBUSY

+ const EINTERNAL

+ const EINVAL

+ const ENOMEM

+ const ERANGE

+ const FIX_FLAG_BYTEORDER

+ const FLEX_MAGIC

+ const FLEX_RES_MAGIC

+ const FLUSH

+ const FLUSHQ

+ const GAT

+ const GET

+ const GETK

+ const GETKQ

+ const GETQ

+ const GET_ALL_VB_SEQNOS

+ const GET_COLLECTIONS_MANIFEST

+ const GET_META

+ const HDR_LEN

+ const HELLO

+ const INCREMENT

+ const INCREMENTQ

+ const KEY_EEXISTS

+ const KEY_ENOENT

+ const LIST_VBUCKETS

+ const LOCKED

+ const NOOP

+ const NOT_INITIALIZED

+ const NOT_MY_VBUCKET

+ const NOT_STORED

+ const NOT_SUPPORTED

+ const NO_BUCKET

+ const OBSERVE

+ const OBSERVE_SEQNO

+ const PREPEND

+ const PREPENDQ

+ const QUIT

+ const QUITQ

+ const RAPPEND

+ const RAPPENDQ

+ const RDECR

+ const RDECRQ

+ const RDELETE

+ const RDELETEQ

+ const REGISTERED_CLIENT

+ const REPLACE

+ const REPLACEQ

+ const REQUEST_KEYS_ONLY

+ const REQ_MAGIC

+ const RES_MAGIC

+ const RGET

+ const RINCR

+ const RINCRQ

+ const ROLLBACK

+ const RPREPEND

+ const RPREPENDQ

+ const RSET

+ const RSETQ

+ const SASL_AUTH

+ const SASL_LIST_MECHS

+ const SASL_STEP

+ const SELECT_BUCKET

+ const SET

+ const SETQ

+ const SET_VBUCKET

+ const STAT

+ const SUBDOC_BAD_MULTI

+ const SUBDOC_GET

+ const SUBDOC_MULTI_LOOKUP

+ const SUBDOC_MULTI_PATH_FAILURE_DELETED

+ const SUBDOC_PATH_NOT_FOUND

+ const SUCCESS

+ const SUPPORT_ACK

+ const SYNC_WRITE_AMBIGUOUS

+ const SYNC_WRITE_IN_PROGRESS

+ const TAKEOVER_VBUCKETS

+ const TAP_ACK

+ const TAP_CHECKPOINT_END

+ const TAP_CHECKPOINT_START

+ const TAP_CONNECT

+ const TAP_DELETE

+ const TAP_FLAG_NETWORK_BYTE_ORDER

+ const TAP_FLUSH

+ const TAP_MUTATION

+ const TAP_NO_VALUE

+ const TAP_OPAQUE

+ const TAP_OPAQUE_CLOSE_BACKFILL

+ const TAP_OPAQUE_CLOSE_TAP_STREAM

+ const TAP_OPAQUE_ENABLE_AUTO_NACK

+ const TAP_OPAQUE_ENABLE_CHECKPOINT_SYNC

+ const TAP_OPAQUE_INITIAL_VBUCKET_STREAM

+ const TAP_VBUCKET_SET

+ const TMPFAIL

+ const UNKNOWN_COLLECTION

+ const UNKNOWN_COMMAND

+ const UPR_ADDSTREAM

+ const UPR_BUFFERACK

+ const UPR_CLOSESTREAM

+ const UPR_CONTROL

+ const UPR_DELETION

+ const UPR_EXPIRATION

+ const UPR_FAILOVERLOG

+ const UPR_FLUSH

+ const UPR_MUTATION

+ const UPR_NOOP

+ const UPR_OPEN

+ const UPR_SNAPSHOT

+ const UPR_STREAMEND

+ const UPR_STREAMREQ

+ const UdTagBegin

+ const UdTagEnd

+ const VERSION

+ var BufferedCommandCodeMap = map[CommandCode]bool

+ var CommandNames map[CommandCode]string

+ var DCP_OPEN_INCLUDE_DELETE_TIMES uint32 = 0x20

+ var DCP_OPEN_INCLUDE_XATTRS uint32 = 0x04

+ var DCP_PRODUCER uint32 = 0x01

+ var ErrorInvalidOp error = fmt.Errorf("Specified method is not applicable")

+ var ErrorObjLenNotMatch error = fmt.Errorf("Object length does not match data")

+ var MaxBodyLen = int(20 * 1024 * 1024)

+ var SUBDOC_FLAG_XATTR uint8 = 0x04

+ var StatusNames map[Status]string

+ var TapConnectFlagNames = map[TapConnectFlag]string

+ var TapFlagParsers = map[TapConnectFlag]TapItemParser

+ func IsFatal(e error) bool

+ func IsNotFound(e error) bool

+ func Merge2HalfByteSlices(src1, src2 []byte) (output []byte)

+ func ShiftByteSliceLeft4Bits(slice []byte) (replacement []byte)

+ func ShiftByteSliceRight4Bits(slice []byte) (replacement []byte)

+ func TapParseBool(r io.Reader) (interface{}, error)

+ func TapParseUint16(r io.Reader) (interface{}, error)

+ func TapParseUint64(r io.Reader) (interface{}, error)

+ func TapParseVBList(r io.Reader) (interface{}, error)

+ type CommandCode uint8

+ func (o CommandCode) IsQuiet() bool

+ func (o CommandCode) String() (rv string)

+ type DurabilityLvl uint8

+ const DuraInvalid

+ const DuraMajority

+ const DuraMajorityAndPersistOnMaster

+ const DuraPersistToMajority

+ type FrameInfo struct

+ ObjData []byte

+ ObjId FrameObjType

+ ObjLen int

+ func (f *FrameInfo) Bytes() (output []byte, halfByteRemaining bool)

+ func (f *FrameInfo) GetDurabilityRequirements() (lvl DurabilityLvl, timeoutProvided bool, timeoutMs uint16, err error)

+ func (f *FrameInfo) GetStreamId() (uint16, error)

+ func (f *FrameInfo) Validate() error

+ type FrameObjType int

+ const FrameBarrier

+ const FrameDcpStreamId

+ const FrameDurability

+ const FrameOpenTracing

+ type MCItem struct

+ Cas uint64

+ Data []byte

+ Expiration uint32

+ Flags uint32

+ type MCRequest struct

+ Body []byte

+ Cas uint64

+ CollId [binary.MaxVarintLen32]byte

+ CollIdLen int

+ DataType uint8

+ ExtMeta []byte

+ Extras []byte

+ FramingElen int

+ FramingExtras []FrameInfo

+ Key []byte

+ Keylen int

+ Opaque uint32

+ Opcode CommandCode

+ VBucket uint16

+ func (req *MCRequest) Bytes() []byte

+ func (req *MCRequest) FillHeaderBytes(data []byte) (int, bool)

+ func (req *MCRequest) HdrSize() int

+ func (req *MCRequest) HeaderBytes() []byte

+ func (req *MCRequest) ParseTapCommands() (TapConnect, error)

+ func (req *MCRequest) Receive(r io.Reader, hdrBytes []byte) (int, error)

+ func (req *MCRequest) Size() int

+ func (req *MCRequest) Transmit(w io.Writer) (n int, err error)

+ func (req MCRequest) String() string

+ type MCResponse struct

+ Body []byte

+ Cas uint64

+ DataType uint8

+ Extras []byte

+ Fatal bool

+ Key []byte

+ Opaque uint32

+ Opcode CommandCode

+ Status Status

+ func (res *MCResponse) Bytes() []byte

+ func (res *MCResponse) Error() string

+ func (res *MCResponse) HeaderBytes() []byte

+ func (res *MCResponse) Receive(r io.Reader, hdrBytes []byte) (n int, err error)

+ func (res *MCResponse) ReceiveWithBuf(r io.Reader, hdrBytes, buf []byte) (n int, err error)

+ func (res *MCResponse) Size() int

+ func (res *MCResponse) Transmit(w io.Writer) (n int, err error)

+ func (res MCResponse) String() string

+ type MCResponsePool struct

+ func NewMCResponsePool() *MCResponsePool

+ func (this *MCResponsePool) Get() *MCResponse

+ func (this *MCResponsePool) Put(r *MCResponse)

+ type Status uint16

+ func (s Status) String() (rv string)

+ type StringMCResponsePool struct

+ func NewStringMCResponsePool(size int) *StringMCResponsePool

+ func (this *StringMCResponsePool) Get() map[string]*MCResponse

+ func (this *StringMCResponsePool) Put(m map[string]*MCResponse)

+ type TapConnect struct

+ Flags map[TapConnectFlag]interface{}

+ Name string

+ RemainingBody []byte

+ type TapConnectFlag uint32

+ func (f TapConnectFlag) SplitFlags() []TapConnectFlag

+ func (f TapConnectFlag) String() string

+ type TapItemParser func(io.Reader) (interface{}, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL