Versions in this module Expand all Collapse all v0 v0.1.0 May 19, 2020 Changes in this version + const FeatureEnabledDataType + const FeatureEnabledXAttrs + const FeatureEnabledXError + const FlagOpenIncludeXattrs + const FlagOpenProducer + const UpdateSecuritySettings + var DefaultBucketDataSourceOptions = &BucketDataSourceOptions + var ErrXAttrsNotSupported = fmt.Errorf("xattrs not supported by server") + func ExponentialBackoffLoop(name string, f func() int, startSleepMS int, backoffFactor float32, ...) + func ParseFailOverLog(body []byte) ([][]uint64, error) + func UPROpen(mc *memcached.Client, name string, option *BucketDataSourceOptions, ...) error + func UpdateSecurityConfig(newConfig *SecurityConfig) error + type AllServerURLsConnectBucketError struct + ServerURLs []string + func (e *AllServerURLsConnectBucketError) Error() string + type AuthFailError struct + ServerURL string + User string + func (e *AuthFailError) Error() string + type Bucket interface + Close func() + GetPoolServices func(string) (*couchbase.PoolServices, error) + GetUUID func() string + VBServerMap func() *couchbase.VBucketServerMap + func ConnectBucket(serverURL, poolName, bucketName string, auth couchbase.AuthHandler) (Bucket, error) + type BucketDataSource interface + Close func() error + Kick func(reason string) error + Start func() error + Stats func(dest *BucketDataSourceStats) error + func NewBucketDataSource(serverURLs []string, poolName string, bucketName string, bucketUUID string, ...) (BucketDataSource, error) + type BucketDataSourceOptions struct + ClusterManagerBackoffFactor float32 + ClusterManagerSleepInitMS int + ClusterManagerSleepMaxMS int + Connect func(protocol, dest string) (*memcached.Client, error) + ConnectBucket func(serverURL, poolName, bucketName string, auth couchbase.AuthHandler) (Bucket, error) + ConnectTLS func(protocol, dest string, tlsConfig *tls.Config) (*memcached.Client, error) + DataManagerBackoffFactor float32 + DataManagerSleepInitMS int + DataManagerSleepMaxMS int + FeedBufferAckThreshold float32 + FeedBufferSizeBytes uint32 + IncludeXAttrs bool + Logf func(fmt string, v ...interface{}) + Name string + NoopTimeIntervalSecs uint32 + PingTimeoutMS int + SeqEnd map[uint16]uint64 + TLSConfig func() *tls.Config + TraceCapacity int + type BucketDataSourceStats struct + TotGetVBucketMetaData uint64 + TotGetVBucketMetaDataErr uint64 + TotGetVBucketMetaDataOk uint64 + TotGetVBucketMetaDataUnmarshalErr uint64 + TotHandShakeErr uint64 + TotKick uint64 + TotKickDeduped uint64 + TotKickOk uint64 + TotPingReq uint64 + TotPingReqDone uint64 + TotPingTimeout uint64 + TotRefreshCluster uint64 + TotRefreshClusterAllServerURLsConnectBucketErr uint64 + TotRefreshClusterAwoken uint64 + TotRefreshClusterAwokenClosed uint64 + TotRefreshClusterAwokenRestart uint64 + TotRefreshClusterAwokenStopped uint64 + TotRefreshClusterBucketUUIDErr uint64 + TotRefreshClusterConnectBucket uint64 + TotRefreshClusterConnectBucketErr uint64 + TotRefreshClusterConnectBucketOk uint64 + TotRefreshClusterDone uint64 + TotRefreshClusterKickWorkers uint64 + TotRefreshClusterKickWorkersClosed uint64 + TotRefreshClusterKickWorkersOk uint64 + TotRefreshClusterKickWorkersStopped uint64 + TotRefreshClusterStopped uint64 + TotRefreshClusterVBMNilErr uint64 + TotRefreshWorker uint64 + TotRefreshWorkerDone uint64 + TotRefreshWorkerOk uint64 + TotRefreshWorkers uint64 + TotRefreshWorkersAddWorker uint64 + TotRefreshWorkersCloseWorker uint64 + TotRefreshWorkersClusterChKicks uint64 + TotRefreshWorkersDone uint64 + TotRefreshWorkersKickWorker uint64 + TotRefreshWorkersLoop uint64 + TotRefreshWorkersLoopDone uint64 + TotRefreshWorkersMasterIdxErr uint64 + TotRefreshWorkersMasterServerErr uint64 + TotRefreshWorkersRemoveWorker uint64 + TotRefreshWorkersSecurityUpdates uint64 + TotRefreshWorkersServerIdxsErr uint64 + TotRefreshWorkersStarted uint64 + TotRefreshWorkersVBMNilErr uint64 + TotRefreshWorkersVBucketIDErr uint64 + TotSelectBucketErr uint64 + TotSetVBucketMetaData uint64 + TotSetVBucketMetaDataErr uint64 + TotSetVBucketMetaDataMarshalErr uint64 + TotSetVBucketMetaDataOk uint64 + TotStart uint64 + TotUPRBufferAck uint64 + TotUPRCloseStream uint64 + TotUPRCloseStreamRes uint64 + TotUPRCloseStreamResErr uint64 + TotUPRCloseStreamResOk uint64 + TotUPRCloseStreamResStateErr uint64 + TotUPRControl uint64 + TotUPRControlErr uint64 + TotUPRDataChange uint64 + TotUPRDataChangeDeletion uint64 + TotUPRDataChangeErr uint64 + TotUPRDataChangeExpiration uint64 + TotUPRDataChangeMutation uint64 + TotUPRDataChangeOk uint64 + TotUPRDataChangeStateErr uint64 + TotUPRNoop uint64 + TotUPRSnapshot uint64 + TotUPRSnapshotOk uint64 + TotUPRSnapshotStart uint64 + TotUPRSnapshotStartErr uint64 + TotUPRSnapshotStateErr uint64 + TotUPRStreamEnd uint64 + TotUPRStreamEndKick uint64 + TotUPRStreamEndStateErr uint64 + TotUPRStreamReq uint64 + TotUPRStreamReqRes uint64 + TotUPRStreamReqResFLogErr uint64 + TotUPRStreamReqResFail uint64 + TotUPRStreamReqResFailENoMem uint64 + TotUPRStreamReqResFailERange uint64 + TotUPRStreamReqResFailNotMyVBucket uint64 + TotUPRStreamReqResKick uint64 + TotUPRStreamReqResRollback uint64 + TotUPRStreamReqResRollbackErr uint64 + TotUPRStreamReqResRollbackStart uint64 + TotUPRStreamReqResStateErr uint64 + TotUPRStreamReqResSuccess uint64 + TotUPRStreamReqResSuccessOk uint64 + TotUPRStreamReqResWantAfterRollbackErr uint64 + TotUPRStreamReqWant uint64 + TotWantCloseRequestedVBucketErr uint64 + TotWantClosingVBucketErr uint64 + TotWorkerAuth uint64 + TotWorkerAuthErr uint64 + TotWorkerAuthFail uint64 + TotWorkerAuthOk uint64 + TotWorkerAuthenticateMemcachedConn uint64 + TotWorkerAuthenticateMemcachedConnErr uint64 + TotWorkerAuthenticateMemcachedConnOk uint64 + TotWorkerBody uint64 + TotWorkerBodyKick uint64 + TotWorkerCleanup uint64 + TotWorkerCleanupDone uint64 + TotWorkerClientClose uint64 + TotWorkerClientCloseDone uint64 + TotWorkerConnect uint64 + TotWorkerConnectErr uint64 + TotWorkerConnectOk uint64 + TotWorkerDone uint64 + TotWorkerHandleRecv uint64 + TotWorkerHandleRecvErr uint64 + TotWorkerHandleRecvOk uint64 + TotWorkerReceive uint64 + TotWorkerReceiveDone uint64 + TotWorkerReceiveErr uint64 + TotWorkerReceiveOk uint64 + TotWorkerReceiveStart uint64 + TotWorkerRecvEndCh uint64 + TotWorkerSendEndCh uint64 + TotWorkerStart uint64 + TotWorkerTransmit uint64 + TotWorkerTransmitDone uint64 + TotWorkerTransmitErr uint64 + TotWorkerTransmitOk uint64 + TotWorkerTransmitStart uint64 + TotWorkerUPROpenErr uint64 + TotWorkerUPROpenOk uint64 + func (s *BucketDataSourceStats) AtomicCopyTo(r *BucketDataSourceStats, fn func(sv uint64, rv uint64) uint64) + type Receiver interface + DataDelete func(vbucketID uint16, key []byte, seq uint64, r *gomemcached.MCRequest) error + DataUpdate func(vbucketID uint16, key []byte, seq uint64, r *gomemcached.MCRequest) error + GetMetaData func(vbucketID uint16) (value []byte, lastSeq uint64, err error) + OnError func(error) + Rollback func(vbucketID uint16, rollbackSeq uint64) error + SetMetaData func(vbucketID uint16, value []byte) error + SnapshotStart func(vbucketID uint16, snapStart, snapEnd uint64, snapType uint32) error + type ReceiverEx interface + RollbackEx func(vbucketID uint16, vbucketUUID uint64, rollbackSeq uint64) error + type SecurityConfig struct + CertFile string + DisableNonSSLPorts bool + EncryptData bool + KeyFile string + type VBucketMetaData struct + FailOverLog [][]uint64 + SeqEnd uint64 + SeqStart uint64 + SnapEnd uint64 + SnapStart uint64 + type VBucketState struct + FailOverLog [][]uint64 + SnapEnd uint64 + SnapSaved bool + SnapStart uint64 + State string