memcached

package

Go to main page

Versions in this module

v0

v0.3.3

Jan 14, 2025

Changes in this version

+ const FeatureSnappyEverywhere

type UprFeatures

+ EnableFlatbuffersSysEvents bool

v0.3.2

Sep 18, 2024

Changes in this version

+ const UPRDefaultNoopIntervalSeconds

type ClientContext

+ IncludeXATTRs bool

+ type MemcachedConnection interface

+ SetDeadline func(time.Time) error

+ SetReadDeadline func(time.Time) error

type UprFeatures

+ func (f *UprFeatures) EnableDeadConnDetection(thresholdSeconds int) error

v0.3.1

Mar 13, 2024

Changes in this version

type Client

+ func (c *Client) EnableDataPool(getter func(uint64) ([]byte, error), doneCb func([]byte)) error

type ClientIface

+ EnableDataPool func(getter func(uint64) ([]byte, error), doneCb func([]byte)) error

v0.3.0

Nov 13, 2023

Changes in this version

+ const FeatureTracing

+ var ConnName = "GoMemcached"

+ func SetConnectionName(name string)

type Client

+ func (c *Client) GetConnName() string

+ func (c *Client) GetErrorMap(errMapVersion gomemcached.ErrorMapVersion) (map[string]interface{}, error)

+ func (c *Client) Replica() bool

+ func (c *Client) SetConnName(name string)

+ func (c *Client) SetSubdoc(vb uint16, key string, ops []SubDocOp, context ...*ClientContext) (*gomemcached.MCResponse, error)

type ClientContext

+ Compressed bool

+ DocumentSubDocPaths bool

+ func (this *ClientContext) Copy() *ClientContext

type ClientIface

+ GetConnName func() string

+ GetErrorMap func(errMapVersion gomemcached.ErrorMapVersion) (map[string]interface{}, error)

+ Replica func() bool

+ SetConnName func(name string)

+ SetSubdoc func(vb uint16, key string, ops []SubDocOp, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ type SubDocOp struct

+ Counter bool

+ Path string

+ Value []byte

+ Xattr bool

type UprEvent

+ func (event *UprEvent) IsStreamEnd() bool

+ func (event *UprEvent) PopulateStreamEndFlags(extras []byte)

v0.2.1

Nov 2, 2022

Changes in this version

+ const FeatureComputeUnits

+ const FeatureHandleThrottle

+ const RandomScanSeed

+ const StreamNotRequested

type Client

+ func (c *Client) CancelRangeScan(vb uint16, uuid []byte, opaque uint32, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) ContinueRangeScan(vb uint16, uuid []byte, opaque uint32, items uint32, timeout uint32, ...) error

+ func (c *Client) CreateRandomScan(vb uint16, collId uint32, sampleSize int, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) CreateRangeScan(vb uint16, collId uint32, start []byte, excludeStart bool, end []byte, ...) (*gomemcached.MCResponse, error)

+ func (c *Client) ValidateKey(vb uint16, key string, context ...*ClientContext) (bool, error)

type ClientIface

+ CancelRangeScan func(vb uint16, uuid []byte, opaque uint32, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ ContinueRangeScan func(vb uint16, uuid []byte, opaque uint32, items uint32, maxSize uint32, ...) error

+ CreateRandomScan func(vb uint16, collId uint32, sampleSize int, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ CreateRangeScan func(vb uint16, collId uint32, start []byte, excludeStart bool, end []byte, ...) (*gomemcached.MCResponse, error)

+ ValidateKey func(vb uint16, key string, context ...*ClientContext) (bool, error)

type UprFeatures

+ SendStreamEndOnClose bool

v0.1.4

Sep 30, 2021

Changes in this version

+ const FeatureOpenTracing

+ const FeaturePreserveExpiry

+ const FeatureSyncReplication

+ var ErrDurabilityNotSupported = errors.New("Durability is not supported")

+ var ErrInvalidHello = errors.New("Invalid HELLO response")

+ var ErrPreserveExpiryNotSupported = errors.New("PreserveExpiry is not supported")

+ var ErrUnSuccessfulHello = errors.New("Unsuccessful HELLO exchange")

type Client

+ func (c *Client) IsFeatureEnabled(feature Feature) bool

+ func (c *Client) SetReplica(r bool)

type ClientContext

+ DurabilityLevel gomemcached.DurabilityLvl

+ DurabilityTimeout time.Duration

+ PreserveExpiry bool

type ClientIface

+ SetReplica func(r bool)

v0.1.3

Apr 16, 2021

v0.1.2

Feb 5, 2021

Changes in this version

type Client

+ func (c *Client) LastBucket() string

+ func (c *Client) StatsFunc(key string, fn func(key, val []byte)) error

type ClientContext

+ User string

type ClientIface

+ LastBucket func() string

+ StatsFunc func(key string, fn func(key, val []byte)) error

v0.1.1

Nov 9, 2020

Changes in this version

type Uleb128

+ func (u Uleb128) ToUint32(cachedLen int) (result uint32, bytesShifted int)

type UprEvent

+ StreamId *uint16

+ func (event *UprEvent) GetOsoBegin() (bool, error)

+ func (event *UprEvent) IsOsoSnapshot() bool

+ func (event *UprEvent) PopulateOso(extras []byte)

type UprFeatures

+ EnableOso bool

v0.1.0

May 11, 2020

Changes in this version

+ const CASDelete

+ const CASQuit

+ const CASStore

+ const CompressionTypeEndMarker

+ const CompressionTypeNone

+ const CompressionTypeSnappy

+ const CompressionTypeStartMarker

+ const FeatureCollections

+ const FeatureDataType

+ const FeatureMutationToken

+ const FeatureSnappyCompression

+ const FeatureTcpNoDelay

+ const FeatureXattr

+ const FeatureXerror

+ const FeedStateClosed

+ const FeedStateInitial

+ const FeedStateOpened

+ const JSONDataType

+ const ObservedLogicallyDeleted

+ const ObservedNotFound

+ const ObservedNotPersisted

+ const ObservedPersisted

+ const SnappyDataType

+ const TapBeginBackfill

+ const TapCheckpointEnd

+ const TapCheckpointStart

+ const TapDeletion

+ const TapEndBackfill

+ const TapMutation

+ const TapNoBackfill

+ const XattrDataType

+ var DefaultDialTimeout = time.Duration(0)

+ var DefaultWriteTimeout = time.Duration(0)

+ var ErrorInvalidLog = errors.New("couchbase.errorInvalidLog")

+ var ErrorInvalidOp error = fmt.Errorf("Invalid Operation")

+ var ErrorInvalidVersion error = fmt.Errorf("Invalid version for parsing")

+ var ErrorNoMaxTTL error = fmt.Errorf("This event has no max TTL")

+ var ErrorValueTooShort error = fmt.Errorf("Value length is too short")

+ var Healthy uint32 = 1

+ var ReceiveHook func(*gomemcached.MCResponse, int, error)

+ var TapRecvHook func(*gomemcached.MCRequest, int, error)

+ var TransmitHook func(*gomemcached.MCRequest, int, error)

+ var UnHealthy uint32 = 0

+ func GetSubDocVal(subPaths []string) (extraBuf, valueBuf []byte)

+ func IfResStatusError(response *gomemcached.MCResponse) bool

+ func SetDefaultDialTimeout(dial time.Duration)

+ func SetDefaultTimeouts(dial, read, write time.Duration)

+ func UnwrapMemcachedError(rv *gomemcached.MCResponse, err error) (*gomemcached.MCResponse, error)

+ type CASState struct

+ Cas uint64

+ Err error

+ Exists bool

+ Value []byte

+ type CasFunc func(current []byte) ([]byte, CasOp)

+ type CasOp uint8

+ func (c CasOp) Error() string

+ type Client struct

+ func Connect(prot, dest string) (rv *Client, err error)

+ func ConnectTLS(prot, dest string, config *tls.Config) (rv *Client, err error)

+ func Wrap(conn memcachedConnection) (rv *Client, err error)

+ func (c *Client) Add(vb uint16, key string, flags int, exp int, body []byte, ...) (*gomemcached.MCResponse, error)

+ func (c *Client) Append(vb uint16, key string, data []byte, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) Auth(user, pass string) (*gomemcached.MCResponse, error)

+ func (c *Client) AuthList() (*gomemcached.MCResponse, error)

+ func (c *Client) AuthPlain(user, pass string) (*gomemcached.MCResponse, error)

+ func (c *Client) AuthScramSha(user, pass string) (*gomemcached.MCResponse, error)

+ func (c *Client) CAS(vb uint16, k string, f CasFunc, initexp int) (*gomemcached.MCResponse, error)

+ func (c *Client) CASNext(vb uint16, k string, exp int, state *CASState) bool

+ func (c *Client) Close() error

+ func (c *Client) CollectionEnabled() bool

+ func (c *Client) CollectionsGetCID(scope string, collection string) (*gomemcached.MCResponse, error)

+ func (c *Client) Conn() io.ReadWriteCloser

+ func (c *Client) Decr(vb uint16, key string, amt, def uint64, exp int, context ...*ClientContext) (uint64, error)

+ func (c *Client) Del(vb uint16, key string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) EnableFeatures(features Features) (*gomemcached.MCResponse, error)

+ func (c *Client) EnableMutationToken() (*gomemcached.MCResponse, error)

+ func (c *Client) Get(vb uint16, key string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) GetAllVbSeqnos(vbSeqnoMap map[uint16]uint64, context ...*ClientContext) (map[uint16]uint64, error)

+ func (c *Client) GetAndTouch(vb uint16, key string, exp int, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) GetBulk(vb uint16, keys []string, rv map[string]*gomemcached.MCResponse, ...) error

+ func (c *Client) GetCollectionsManifest() (*gomemcached.MCResponse, error)

+ func (c *Client) GetMeta(vb uint16, key string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) GetRandomDoc(context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) GetSubdoc(vb uint16, key string, subPaths []string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ func (c *Client) Hijack() io.ReadWriteCloser

+ func (c *Client) Incr(vb uint16, key string, amt, def uint64, exp int, context ...*ClientContext) (uint64, error)

+ func (c *Client) Observe(vb uint16, key string) (result ObserveResult, err error)

+ func (c *Client) ObserveSeq(vb uint16, vbuuid uint64) (result *ObserveSeqResult, err error)

+ func (c *Client) Receive() (*gomemcached.MCResponse, error)

+ func (c *Client) ReceiveWithDeadline(deadline time.Time) (*gomemcached.MCResponse, error)

+ func (c *Client) SelectBucket(bucket string) (*gomemcached.MCResponse, error)

+ func (c *Client) Send(req *gomemcached.MCRequest) (rv *gomemcached.MCResponse, err error)

+ func (c *Client) Set(vb uint16, key string, flags int, exp int, body []byte, ...) (*gomemcached.MCResponse, error)

+ func (c *Client) SetCas(vb uint16, key string, flags int, exp int, cas uint64, body []byte, ...) (*gomemcached.MCResponse, error)

+ func (c *Client) SetDeadline(t time.Time)

+ func (c *Client) SetKeepAliveOptions(interval time.Duration)

+ func (c *Client) SetReadDeadline(t time.Time)

+ func (c *Client) Stats(key string) ([]StatValue, error)

+ func (c *Client) StatsMap(key string) (map[string]string, error)

+ func (c *Client) StatsMapForSpecifiedStats(key string, statsMap map[string]string) error

+ func (c *Client) Transmit(req *gomemcached.MCRequest) error

+ func (c *Client) TransmitResponse(res *gomemcached.MCResponse) error

+ func (c *Client) TransmitWithDeadline(req *gomemcached.MCRequest, deadline time.Time) error

+ func (c Client) IsHealthy() bool

+ func (mc *Client) NewUprFeed() (*UprFeed, error)

+ func (mc *Client) NewUprFeedIface() (UprFeedIface, error)

+ func (mc *Client) NewUprFeedWithConfig(ackByClient bool) (*UprFeed, error)

+ func (mc *Client) NewUprFeedWithConfigIface(ackByClient bool) (UprFeedIface, error)

+ func (mc *Client) StartTapFeed(args TapArguments) (*TapFeed, error)

+ func (mc *Client) UprGetFailoverLog(vb []uint16) (map[uint16]*FailoverLog, error)

+ type ClientContext struct

+ CollId uint32

+ VbState *VbStateType

+ func (context *ClientContext) InitExtras(req *gomemcached.MCRequest, client *Client)

+ type ClientIface interface

+ Add func(vb uint16, key string, flags int, exp int, body []byte, ...) (*gomemcached.MCResponse, error)

+ Append func(vb uint16, key string, data []byte, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ Auth func(user, pass string) (*gomemcached.MCResponse, error)

+ AuthList func() (*gomemcached.MCResponse, error)

+ AuthPlain func(user, pass string) (*gomemcached.MCResponse, error)

+ AuthScramSha func(user, pass string) (*gomemcached.MCResponse, error)

+ CAS func(vb uint16, k string, f CasFunc, initexp int) (*gomemcached.MCResponse, error)

+ CASNext func(vb uint16, k string, exp int, state *CASState) bool

+ Close func() error

+ CollectionEnabled func() bool

+ CollectionsGetCID func(scope string, collection string) (*gomemcached.MCResponse, error)

+ Decr func(vb uint16, key string, amt, def uint64, exp int, context ...*ClientContext) (uint64, error)

+ Del func(vb uint16, key string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ EnableFeatures func(features Features) (*gomemcached.MCResponse, error)

+ EnableMutationToken func() (*gomemcached.MCResponse, error)

+ Get func(vb uint16, key string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ GetAllVbSeqnos func(vbSeqnoMap map[uint16]uint64, context ...*ClientContext) (map[uint16]uint64, error)

+ GetAndTouch func(vb uint16, key string, exp int, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ GetBulk func(vb uint16, keys []string, rv map[string]*gomemcached.MCResponse, ...) error

+ GetCollectionsManifest func() (*gomemcached.MCResponse, error)

+ GetMeta func(vb uint16, key string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ GetRandomDoc func(context ...*ClientContext) (*gomemcached.MCResponse, error)

+ GetSubdoc func(vb uint16, key string, subPaths []string, context ...*ClientContext) (*gomemcached.MCResponse, error)

+ Hijack func() io.ReadWriteCloser

+ Incr func(vb uint16, key string, amt, def uint64, exp int, context ...*ClientContext) (uint64, error)

+ NewUprFeed func() (*UprFeed, error)

+ NewUprFeedIface func() (UprFeedIface, error)

+ NewUprFeedWithConfig func(ackByClient bool) (*UprFeed, error)

+ NewUprFeedWithConfigIface func(ackByClient bool) (UprFeedIface, error)

+ Observe func(vb uint16, key string) (result ObserveResult, err error)

+ ObserveSeq func(vb uint16, vbuuid uint64) (result *ObserveSeqResult, err error)

+ Receive func() (*gomemcached.MCResponse, error)

+ ReceiveWithDeadline func(deadline time.Time) (*gomemcached.MCResponse, error)

+ SelectBucket func(bucket string) (*gomemcached.MCResponse, error)

+ Send func(req *gomemcached.MCRequest) (rv *gomemcached.MCResponse, err error)

+ Set func(vb uint16, key string, flags int, exp int, body []byte, ...) (*gomemcached.MCResponse, error)

+ SetCas func(vb uint16, key string, flags int, exp int, cas uint64, body []byte, ...) (*gomemcached.MCResponse, error)

+ SetDeadline func(t time.Time)

+ SetKeepAliveOptions func(interval time.Duration)

+ SetReadDeadline func(t time.Time)

+ Stats func(key string) ([]StatValue, error)

+ StatsMap func(key string) (map[string]string, error)

+ StatsMapForSpecifiedStats func(key string, statsMap map[string]string) error

+ Transmit func(req *gomemcached.MCRequest) error

+ TransmitResponse func(res *gomemcached.MCResponse) error

+ TransmitWithDeadline func(req *gomemcached.MCRequest, deadline time.Time) error

+ UprGetFailoverLog func(vb []uint16) (map[uint16]*FailoverLog, error)

+ type CollectionChangedEvent interface

+ GetCollectionId func() (uint32, error)

+ GetManifestId func() (uint64, error)

+ GetMaxTTL func() (uint32, error)

+ type CollectionCreateEvent interface

+ GetCollectionId func() (uint32, error)

+ GetManifestId func() (uint64, error)

+ GetMaxTTL func() (uint32, error)

+ GetScopeId func() (uint32, error)

+ GetSystemEventName func() (string, error)

+ type CollectionDropEvent interface

+ GetCollectionId func() (uint32, error)

+ GetManifestId func() (uint64, error)

+ GetScopeId func() (uint32, error)

+ type CollectionsFilter struct

+ CollectionsList []uint32

+ ManifestUid uint64

+ ScopeId uint32

+ StreamId uint16

+ UseManifestUid bool

+ UseStreamId bool

+ func (c *CollectionsFilter) IsValid() error

+ func (c *CollectionsFilter) ToStreamReqBody() ([]byte, error)

+ type DcpStreamType int32

+ const CollectionsNonStreamId

+ const CollectionsStreamId

+ const NonCollectionStream

+ var UninitializedStream DcpStreamType = -1

+ func (t DcpStreamType) String() string

+ type FailoverLog [][2]uint64

+ func (flogp *FailoverLog) Latest() (vbuuid, seqno uint64, err error)

+ type Feature uint16

+ type Features []Feature

+ type FeedState int

+ func (fs FeedState) String() string

+ type ObserveResult struct

+ Cas uint64

+ PersistenceTime time.Duration

+ ReplicationTime time.Duration

+ Status ObservedStatus

+ func (result ObserveResult) CheckPersistence(cas uint64, deletion bool) (persisted bool, overwritten bool)

+ type ObserveSeqResult struct

+ CurrentSeqNo uint64

+ Failover uint8

+ LastPersistedSeqNo uint64

+ LastSeqNo uint64

+ OldVbuuid uint64

+ VbId uint16

+ Vbuuid uint64

+ type ObservedStatus uint8

+ type PriorityType string

+ const PriorityDisabled

+ const PriorityHigh

+ const PriorityLow

+ const PriorityMed

+ type ScopeCreateEvent interface

+ GetManifestId func() (uint64, error)

+ GetScopeId func() (uint32, error)

+ GetSystemEventName func() (string, error)

+ type ScopeDropEvent interface

+ GetManifestId func() (uint64, error)

+ GetScopeId func() (uint32, error)

+ type StatValue struct

+ Key string

+ Val string

+ type SystemEventType int

+ const CollectionChanged

+ const CollectionCreate

+ const CollectionDrop

+ const CollectionFlush

+ const InvalidSysEvent

+ const ScopeCreate

+ const ScopeDrop

+ type TapArguments struct

+ Backfill uint64

+ Checkpoint bool

+ ClientName string

+ Dump bool

+ KeysOnly bool

+ RegisteredClient bool

+ SupportAck bool

+ Takeover bool

+ VBuckets []uint16

+ func DefaultTapArguments() TapArguments

+ type TapEvent struct

+ Cas uint64

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ Opcode TapOpcode

+ VBucket uint16

+ Value []byte

+ func (event TapEvent) String() string

+ type TapFeed struct

+ C <-chan TapEvent

+ Error error

+ func (feed *TapFeed) Close()

+ type TapOpcode uint8

+ func (opcode TapOpcode) String() string

+ type Uleb128 []byte

+ func (u Uleb128) ToUint64(cachedLen int) (result uint64, bytesShifted int)

+ type UprEvent struct

+ AckSize uint32

+ Cas uint64

+ CollectionId uint64

+ DataType uint8

+ Error error

+ Expiry uint32

+ ExtMeta []byte

+ FailoverLog *FailoverLog

+ Flags uint32

+ Key []byte

+ LockTime uint32

+ MetadataSize uint16

+ OldValue []byte

+ Opaque uint16

+ Opcode gomemcached.CommandCode

+ RevSeqno uint64

+ Seqno uint64

+ SnapendSeq uint64

+ SnapshotType uint32

+ SnapstartSeq uint64

+ Status gomemcached.Status

+ SysEventVersion uint8

+ SystemEvent SystemEventType

+ VBucket uint16

+ VBuuid uint64

+ Value []byte

+ ValueLen int

+ func (event *UprEvent) GetCollectionId() (uint32, error)

+ func (event *UprEvent) GetManifestId() (uint64, error)

+ func (event *UprEvent) GetMaxTTL() (uint32, error)

+ func (event *UprEvent) GetScopeId() (uint32, error)

+ func (event *UprEvent) GetSystemEventName() (string, error)

+ func (event *UprEvent) IsCollectionType() bool

+ func (event *UprEvent) IsSeqnoAdv() bool

+ func (event *UprEvent) IsSnappyDataType() bool

+ func (event *UprEvent) IsSystemEvent() bool

+ func (event *UprEvent) PopulateEvent(extras []byte)

+ func (event *UprEvent) PopulateFieldsBasedOnStreamType(rq gomemcached.MCRequest, streamType DcpStreamType)

+ func (event *UprEvent) PopulateSeqnoAdv(extras []byte)

+ func (event *UprEvent) String() string

+ type UprFeatures struct

+ CompressionType int

+ DcpPriority PriorityType

+ EnableExpiry bool

+ EnableStreamId bool

+ IncludeDeletionTime bool

+ Xattribute bool

+ type UprFeed struct

+ C <-chan *UprEvent

+ Error error

+ func (feed *UprFeed) ClientAck(event *UprEvent) error

+ func (feed *UprFeed) Close()

+ func (feed *UprFeed) CloseStream(vbno, opaqueMSB uint16) error

+ func (feed *UprFeed) Closed() bool

+ func (feed *UprFeed) GetError() error

+ func (feed *UprFeed) GetUprEventCh() <-chan *UprEvent

+ func (feed *UprFeed) GetUprStats() *UprStats

+ func (feed *UprFeed) SetPriorityAsync(p PriorityType) error

+ func (feed *UprFeed) StartFeed() error

+ func (feed *UprFeed) StartFeedWithConfig(datachan_len int) error

+ func (feed *UprFeed) UprOpen(name string, sequence uint32, bufSize uint32) error

+ func (feed *UprFeed) UprOpenWithFeatures(name string, sequence uint32, bufSize uint32, features UprFeatures) (error, UprFeatures)

+ func (feed *UprFeed) UprOpenWithXATTR(name string, sequence uint32, bufSize uint32) error

+ func (feed *UprFeed) UprRequestCollectionsStream(vbno, opaqueMSB uint16, flags uint32, ...) error

+ func (feed *UprFeed) UprRequestStream(vbno, opaqueMSB uint16, flags uint32, ...) error

+ type UprFeedIface interface

+ ClientAck func(event *UprEvent) error

+ Close func()

+ CloseStream func(vbno, opaqueMSB uint16) error

+ Closed func() bool

+ GetError func() error

+ GetUprEventCh func() <-chan *UprEvent

+ GetUprStats func() *UprStats

+ SetPriorityAsync func(p PriorityType) error

+ StartFeed func() error

+ StartFeedWithConfig func(datachan_len int) error

+ UprOpen func(name string, sequence uint32, bufSize uint32) error

+ UprOpenWithFeatures func(name string, sequence uint32, bufSize uint32, features UprFeatures) (error, UprFeatures)

+ UprOpenWithXATTR func(name string, sequence uint32, bufSize uint32) error

+ UprRequestCollectionsStream func(vbno, opaqueMSB uint16, flags uint32, ...) error

+ UprRequestStream func(vbno, opaqueMSB uint16, flags uint32, ...) error

+ type UprStats struct

+ TotalBufferAckSent uint64

+ TotalBytes uint64

+ TotalMutation uint64

+ TotalSnapShot uint64

+ type UprStream struct

+ EndSeq uint64

+ StartSeq uint64

+ StreamType DcpStreamType

+ Vbucket uint16

+ Vbuuid uint64

+ type VBSeqnos [][2]uint64

+ type VbStateType uint8

+ const VbActive

+ const VbAlive

+ const VbDead

+ const VbPending

+ const VbReplica

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