Versions in this module Expand all Collapse all v8 v8.0.0 Mar 18, 2019 Changes in this version + const BinaryType + const CapiService + const CbasService + const DatatypeFlagCompressed + const DatatypeFlagJson + const DatatypeFlagXattrs + const DcpAgentPriorityHigh + const DcpAgentPriorityLow + const DcpAgentPriorityMed + const DcpOpenFlagIncludeXattrs + const DcpOpenFlagNoValue + const DcpOpenFlagNotifier + const DcpOpenFlagProducer + const DcpStreamAddFlagActiveOnly + const DcpStreamAddFlagLatest + const DcpStreamAddFlagStrictVBUUID + const FeatureAltRequests + const FeatureClusterMapNotif + const FeatureCollections + const FeatureDatatype + const FeatureDuplex + const FeatureDurations + const FeatureEnhancedDurability + const FeatureJson + const FeatureSelectBucket + const FeatureSeqNo + const FeatureSnappy + const FeatureTcpDelay + const FeatureTcpNoDelay + const FeatureTls + const FeatureUnorderedExec + const FeatureXattr + const FeatureXerror + const ForceMetaOp + const FtsService + const IsExpiration + const JsonType + const KeyStateDeleted + const KeyStateNotFound + const KeyStateNotPersisted + const KeyStatePersisted + const Majority + const MajorityAndPersistOnMaster + const MemdService + const MgmtService + const N1qlService + const NoCompression + const PersistToMajority + const RegenerateCas + const SkipConflictResolution + const StatusAccessError + const StatusAuthContinue + const StatusAuthError + const StatusAuthStale + const StatusBadDelta + const StatusBusy + const StatusCollectionUnknown + const StatusDurabilityImpossible + const StatusDurabilityInvalidLevel + const StatusInternalError + const StatusInvalidArgs + const StatusKeyExists + const StatusKeyNotFound + const StatusLocked + const StatusNoBucket + const StatusNotInitialized + const StatusNotMyVBucket + const StatusNotStored + const StatusNotSupported + const StatusOutOfMemory + const StatusRangeError + const StatusRollback + const StatusScopeUnknown + const StatusSubDocBadCombo + const StatusSubDocBadDelta + const StatusSubDocBadMulti + const StatusSubDocBadRange + const StatusSubDocCantInsert + const StatusSubDocDocTooDeep + const StatusSubDocMultiPathFailureDeleted + const StatusSubDocNotJson + const StatusSubDocPathExists + const StatusSubDocPathInvalid + const StatusSubDocPathMismatch + const StatusSubDocPathNotFound + const StatusSubDocPathTooBig + const StatusSubDocSuccessDeleted + const StatusSubDocValueTooDeep + const StatusSubDocXattrCannotModifyVAttr + const StatusSubDocXattrInvalidFlagCombo + const StatusSubDocXattrInvalidKeyCombo + const StatusSubDocXattrUnknownMacro + const StatusSubDocXattrUnknownVAttr + const StatusSuccess + const StatusSyncWriteAmbiguous + const StatusSyncWriteInProgress + const StatusTmpFail + const StatusTooBig + const StatusUnknownCommand + const StreamEventCollectionChanged + const StreamEventCollectionCreate + const StreamEventCollectionDelete + const StreamEventCollectionFlush + const StreamEventScopeCreate + const StreamEventScopeDelete + const StringType + const SubDocOpAddDoc + const SubDocOpArrayAddUnique + const SubDocOpArrayInsert + const SubDocOpArrayPushFirst + const SubDocOpArrayPushLast + const SubDocOpCounter + const SubDocOpDelete + const SubDocOpDeleteDoc + const SubDocOpDictAdd + const SubDocOpDictSet + const SubDocOpExists + const SubDocOpGet + const SubDocOpGetCount + const SubDocOpGetDoc + const SubDocOpReplace + const SubDocOpSetDoc + const SubdocDocFlagAccessDeleted + const SubdocDocFlagMkDoc + const SubdocDocFlagNone + const SubdocDocFlagReplaceDoc + const SubdocFlagExpandMacros + const SubdocFlagMkDirP + const SubdocFlagNone + const SubdocFlagXattrPath + const UnknownCompression + const UnknownType + const UseLwwConflictResolution + const VbucketStateActive + const VbucketStateDead + const VbucketStatePending + const VbucketStateReplica + var ErrAccessError = newSimpleError(StatusAccessError) + var ErrAuthContinue = newSimpleError(StatusAuthContinue) + var ErrAuthError = newSimpleError(StatusAuthError) + var ErrAuthStale = newSimpleError(StatusAuthStale) + var ErrBadDelta = newSimpleError(StatusBadDelta) + var ErrBadHosts = errors.New("failed to connect to any of the specified hosts") + var ErrBusy = newSimpleError(StatusBusy) + var ErrCancelled = errors.New("Operation was cancelled by the user.") + var ErrCliInternalError = errors.New("client internal error") + var ErrCollectionUnknown = newSimpleError(StatusCollectionUnknown) + var ErrCollectionsUnsupported = errors.New("Collections are not enabled.") + var ErrDispatchFail = errors.New("failed to dispatch operation") + var ErrDurabilityImpossible = newSimpleError(StatusDurabilityImpossible) + var ErrDurabilityInvalidLevel = newSimpleError(StatusDurabilityInvalidLevel) + var ErrEnhancedDurabilityUnsupported = errors.New("Enhanced durability is not supported by this server version.") + var ErrInternalError = newSimpleError(StatusInternalError) + var ErrInvalidArgs = newSimpleError(StatusInvalidArgs) + var ErrInvalidCert = errors.New("certificate is invalid") + var ErrInvalidCredentials = errors.New("An invalid set of credentials was provided.") + var ErrInvalidReplica = errors.New("specific server index is invalid") + var ErrInvalidServer = errors.New("specific server index is invalid") + var ErrInvalidService = errors.New("Invalid service specified") + var ErrInvalidVBucket = errors.New("specific vbucket index is invalid") + var ErrKeyExists = newSimpleError(StatusKeyExists) + var ErrKeyNotFound = newSimpleError(StatusKeyNotFound) + var ErrNetwork = &networkError + var ErrNoAuthMethod = errors.New("no supported auth") + var ErrNoBucket = newSimpleError(StatusNoBucket) + var ErrNoCapiService = errors.New("No available capi nodes.") + var ErrNoCbasService = errors.New("No available cbas nodes.") + var ErrNoFtsService = errors.New("No available fts nodes.") + var ErrNoMgmtService = errors.New("No available management nodes.") + var ErrNoN1qlService = errors.New("No available n1ql nodes.") + var ErrNoReplicas = errors.New("no replicas responded in time") + var ErrNoServer = errors.New("no server available for this vbucket") + var ErrNonZeroCas = errors.New("Cas value must be 0.") + var ErrNotInitialized = newSimpleError(StatusNotInitialized) + var ErrNotMyVBucket = newSimpleError(StatusNotMyVBucket) + var ErrNotStored = newSimpleError(StatusNotStored) + var ErrNotSupported = newSimpleError(StatusNotSupported) + var ErrOutOfMemory = newSimpleError(StatusOutOfMemory) + var ErrOverload = &overloadError + var ErrProtocol = errors.New("failed to parse server response") + var ErrRangeError = newSimpleError(StatusRangeError) + var ErrRollback = newSimpleError(StatusRollback) + var ErrScopeUnknown = newSimpleError(StatusScopeUnknown) + var ErrShutdown = &shutdownError + var ErrStreamClosed = &streamEndError + var ErrStreamDisconnected = &streamEndError + var ErrStreamFilterEmpty = &streamEndError + var ErrStreamStateChanged = &streamEndError + var ErrStreamTooSlow = &streamEndError + var ErrSubDocBadCombo = newSimpleError(StatusSubDocBadCombo) + var ErrSubDocBadDelta = newSimpleError(StatusSubDocBadDelta) + var ErrSubDocBadMulti = newSimpleError(StatusSubDocBadMulti) + var ErrSubDocBadRange = newSimpleError(StatusSubDocBadRange) + var ErrSubDocCantInsert = newSimpleError(StatusSubDocCantInsert) + var ErrSubDocDocTooDeep = newSimpleError(StatusSubDocDocTooDeep) + var ErrSubDocMultiPathFailureDeleted = newSimpleError(StatusSubDocMultiPathFailureDeleted) + var ErrSubDocNotJson = newSimpleError(StatusSubDocNotJson) + var ErrSubDocPathExists = newSimpleError(StatusSubDocPathExists) + var ErrSubDocPathInvalid = newSimpleError(StatusSubDocPathInvalid) + var ErrSubDocPathMismatch = newSimpleError(StatusSubDocPathMismatch) + var ErrSubDocPathNotFound = newSimpleError(StatusSubDocPathNotFound) + var ErrSubDocPathTooBig = newSimpleError(StatusSubDocPathTooBig) + var ErrSubDocSuccessDeleted = newSimpleError(StatusSubDocSuccessDeleted) + var ErrSubDocValueTooDeep = newSimpleError(StatusSubDocValueTooDeep) + var ErrSubDocXattrCannotModifyVAttr = newSimpleError(StatusSubDocXattrCannotModifyVAttr) + var ErrSubDocXattrInvalidFlagCombo = newSimpleError(StatusSubDocXattrInvalidFlagCombo) + var ErrSubDocXattrInvalidKeyCombo = newSimpleError(StatusSubDocXattrInvalidKeyCombo) + var ErrSubDocXattrUnknownMacro = newSimpleError(StatusSubDocXattrUnknownMacro) + var ErrSubDocXattrUnknownVAttr = newSimpleError(StatusSubDocXattrUnknownVAttr) + var ErrSyncWriteAmbiguous = newSimpleError(StatusSyncWriteAmbiguous) + var ErrSyncWriteInProgess = newSimpleError(StatusSyncWriteInProgress) + var ErrTimeout = &timeoutError + var ErrTmpFail = newSimpleError(StatusTmpFail) + var ErrTooBig = newSimpleError(StatusTooBig) + var ErrUnknownCommand = newSimpleError(StatusUnknownCommand) + func AcquireTimer(d time.Duration) *time.Timer + func DecodeCommonFlags(flags uint32) (DataType, CompressionType) + func EncodeCommonFlags(valueType DataType, compression CompressionType) uint32 + func ErrorCause(err error) error + func IsErrorStatus(err error, code StatusCode) bool + func ReleaseTimer(t *time.Timer, wasRead bool) + func SaslAuthBest(username, password string, client AuthClient, deadline time.Time) error + func SaslAuthPlain(username, password string, client AuthClient, deadline time.Time) error + func SaslAuthScramSha1(username, password string, client AuthClient, deadline time.Time) error + func SaslAuthScramSha256(username, password string, client AuthClient, deadline time.Time) error + func SaslAuthScramSha512(username, password string, client AuthClient, deadline time.Time) error + func SetLogRedactionLevel(level LogRedactLevel) + func SetLogger(logger Logger) + func Version() string + type AddOptions struct + CollectionName string + Datatype uint8 + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Flags uint32 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + Value []byte + type AdjoinExCallback func(*AdjoinResult, error) + type AdjoinOptions struct + Cas Cas + CollectionName string + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + Value []byte + type AdjoinResult struct + Cas Cas + MutationToken MutationToken + type Agent struct + func CreateAgent(configIn *AgentConfig) (*Agent, error) + func CreateDcpAgent(configIn *AgentConfig, dcpStreamName string, openFlags DcpOpenFlag) (*Agent, error) + func (agent *Agent) AddEx(opts AddOptions, cb StoreExCallback) (PendingOp, error) + func (agent *Agent) AddInEx(opts StoreInOptions, cb StoreInExCallback) (PendingOp, error) + func (agent *Agent) AddUniqueInEx(opts StoreInOptions, cb StoreInExCallback) (PendingOp, error) + func (agent *Agent) AppendEx(opts AdjoinOptions, cb AdjoinExCallback) (PendingOp, error) + func (agent *Agent) ArrayInsertInEx(opts StoreInOptions, cb StoreInExCallback) (PendingOp, error) + func (agent *Agent) BucketUUID() string + func (agent *Agent) CapiEps() []string + func (agent *Agent) CbasEps() []string + func (agent *Agent) ClientId() string + func (agent *Agent) Close() error + func (agent *Agent) CloseStream(vbId uint16, cb CloseStreamCallback) (PendingOp, error) + func (agent *Agent) CloseStreamWithId(vbId uint16, streamId uint16, cb CloseStreamCallback) (PendingOp, error) + func (agent *Agent) CounterInEx(opts CounterInOptions, cb CounterInExCallback) (PendingOp, error) + func (agent *Agent) DecrementEx(opts CounterOptions, cb CounterExCallback) (PendingOp, error) + func (agent *Agent) DeleteEx(opts DeleteOptions, cb DeleteExCallback) (PendingOp, error) + func (agent *Agent) DeleteInEx(opts DeleteInOptions, cb DeleteInExCallback) (PendingOp, error) + func (agent *Agent) DeleteMetaEx(opts DeleteMetaOptions, cb DeleteMetaExCallback) (PendingOp, error) + func (agent *Agent) Diagnostics() (*DiagnosticInfo, error) + func (agent *Agent) DoHttpRequest(req *HttpRequest) (*HttpResponse, error) + func (agent *Agent) ExistsInEx(opts ExistsInOptions, cb ExistsInExCallback) (PendingOp, error) + func (agent *Agent) FtsEps() []string + func (agent *Agent) GetAndLockEx(opts GetAndLockOptions, cb GetAndLockExCallback) (PendingOp, error) + func (agent *Agent) GetAndTouchEx(opts GetAndTouchOptions, cb GetAndTouchExCallback) (PendingOp, error) + func (agent *Agent) GetCollectionID(scopeName string, collectionName string, opts GetCollectionIDOptions, ...) (PendingOp, error) + func (agent *Agent) GetCollectionManifest(cb ManifestCallback) (PendingOp, error) + func (agent *Agent) GetEx(opts GetOptions, cb GetExCallback) (PendingOp, error) + func (agent *Agent) GetFailoverLog(vbId uint16, cb GetFailoverLogCallback) (PendingOp, error) + func (agent *Agent) GetInEx(opts GetInOptions, cb GetInExCallback) (PendingOp, error) + func (agent *Agent) GetMetaEx(opts GetMetaOptions, cb GetMetaExCallback) (PendingOp, error) + func (agent *Agent) GetRandomEx(opts GetRandomOptions, cb GetRandomExCallback) (PendingOp, error) + func (agent *Agent) GetReplicaEx(opts GetReplicaOptions, cb GetReplicaExCallback) (PendingOp, error) + func (agent *Agent) GetVbucketSeqnos(serverIdx int, state VbucketState, cb GetVBucketSeqnosCallback) (PendingOp, error) + func (agent *Agent) GetVbucketSeqnosWithCollectionId(serverIdx int, state VbucketState, collectionId uint32, ...) (PendingOp, error) + func (agent *Agent) HasCollectionsSupport() bool + func (agent *Agent) HttpClient() *http.Client + func (agent *Agent) IncrementEx(opts CounterOptions, cb CounterExCallback) (PendingOp, error) + func (agent *Agent) IsSecure() bool + func (agent *Agent) KeyToServer(key []byte, replicaIdx uint32) int + func (agent *Agent) KeyToVbucket(key []byte) uint16 + func (agent *Agent) LookupInEx(opts LookupInOptions, cb LookupInExCallback) (PendingOp, error) + func (agent *Agent) MgmtEps() []string + func (agent *Agent) MutateInEx(opts MutateInOptions, cb MutateInExCallback) (PendingOp, error) + func (agent *Agent) N1qlEps() []string + func (agent *Agent) NumReplicas() int + func (agent *Agent) NumServers() int + func (agent *Agent) NumVbuckets() int + func (agent *Agent) ObserveEx(opts ObserveOptions, cb ObserveExCallback) (PendingOp, error) + func (agent *Agent) ObserveVbEx(opts ObserveVbOptions, cb ObserveVbExCallback) (PendingOp, error) + func (agent *Agent) OpenStream(vbId uint16, flags DcpStreamAddFlag, vbUuid VbUuid, ...) (PendingOp, error) + func (agent *Agent) PingKvEx(opts PingKvOptions, cb PingKvExCallback) (PendingOp, error) + func (agent *Agent) PrependEx(opts AdjoinOptions, cb AdjoinExCallback) (PendingOp, error) + func (agent *Agent) PushBackInEx(opts StoreInOptions, cb StoreInExCallback) (PendingOp, error) + func (agent *Agent) PushFrontInEx(opts StoreInOptions, cb StoreInExCallback) (PendingOp, error) + func (agent *Agent) ReplaceEx(opts ReplaceOptions, cb StoreExCallback) (PendingOp, error) + func (agent *Agent) ReplaceInEx(opts StoreInOptions, cb StoreInExCallback) (PendingOp, error) + func (agent *Agent) ServerConnectTimeout() time.Duration + func (agent *Agent) SetEx(opts SetOptions, cb StoreExCallback) (PendingOp, error) + func (agent *Agent) SetInEx(opts StoreInOptions, cb StoreInExCallback) (PendingOp, error) + func (agent *Agent) SetMetaEx(opts SetMetaOptions, cb SetMetaExCallback) (PendingOp, error) + func (agent *Agent) SetServerConnectTimeout(timeout time.Duration) + func (agent *Agent) StatsEx(opts StatsOptions, cb StatsExCallback) (PendingOp, error) + func (agent *Agent) TouchEx(opts TouchOptions, cb TouchExCallback) (PendingOp, error) + func (agent *Agent) UnlockEx(opts UnlockOptions, cb UnlockExCallback) (PendingOp, error) + func (agent *Agent) VbucketToServer(vbID uint16, replicaIdx uint32) int + func (agent *Agent) VbucketsOnServer(index int) []uint16 + type AgentConfig struct + Auth AuthProvider + AuthHandler AuthFunc + BucketName string + CccpMaxWait time.Duration + CccpPollPeriod time.Duration + CompressionMinRatio float64 + CompressionMinSize int + ConnectTimeout time.Duration + DcpAgentPriority DcpAgentPriority + DisableDecompression bool + EnableStreamId bool + HttpAddrs []string + HttpIdleConnTimeout time.Duration + HttpMaxIdleConns int + HttpMaxIdleConnsPerHost int + HttpRedialPeriod time.Duration + HttpRetryDelay time.Duration + KvPoolSize int + MaxQueueSize int + MemdAddrs []string + NetworkType string + NmvRetryDelay time.Duration + NoRootTraceSpans bool + ServerConnectTimeout time.Duration + TlsConfig *tls.Config + Tracer opentracing.Tracer + UseCollections bool + UseCompression bool + UseDcpExpiry bool + UseDurations bool + UseEnhancedErrors bool + UseKvErrorMaps bool + UseMutationTokens bool + UseZombieLogger bool + UserString string + ZombieLoggerInterval time.Duration + ZombieLoggerSampleSize int + func (config *AgentConfig) FromConnStr(connStr string) error + type AuthClient interface + Address func() string + ExecSaslAuth func(k, v []byte, deadline time.Time) ([]byte, error) + ExecSaslListMechs func(deadline time.Time) ([]string, error) + ExecSaslStep func(k, v []byte, deadline time.Time) ([]byte, error) + ExecSelectBucket func(b []byte, deadline time.Time) error + SupportsFeature func(feature HelloFeature) bool + type AuthCredsRequest struct + Endpoint string + Service ServiceType + type AuthFunc func(client AuthClient, deadline time.Time) error + type AuthProvider interface + Credentials func(req AuthCredsRequest) ([]UserPassPair, error) + type Cas uint64 + type CloseStreamCallback func(error) + type CollectionIdCallback func(manifestID uint64, collectionID uint32, err error) + type CompressionType uint32 + type CounterExCallback func(*CounterResult, error) + type CounterInExCallback func(*CounterInResult, error) + type CounterInOptions StoreInOptions + type CounterInResult struct + Cas Cas + MutationToken MutationToken + Value []byte + type CounterOptions struct + Cas Cas + CollectionName string + Delta uint64 + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Initial uint64 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + type CounterResult struct + Cas Cas + MutationToken MutationToken + Value uint64 + type DataType uint32 + type DatatypeFlag uint8 + type DcpAgentPriority uint8 + type DcpOpenFlag uint32 + type DcpStreamAddFlag uint32 + type DeleteExCallback func(*DeleteResult, error) + type DeleteInExCallback func(*DeleteInResult, error) + type DeleteInOptions struct + Cas Cas + CollectionName string + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Flags SubdocFlag + Key []byte + Path string + ScopeName string + TraceContext opentracing.SpanContext + type DeleteInResult struct + Cas Cas + MutationToken MutationToken + type DeleteMetaExCallback func(*DeleteMetaResult, error) + type DeleteMetaOptions struct + Cas Cas + CollectionName string + Datatype uint8 + Expiry uint32 + Extra []byte + Flags uint32 + Key []byte + Options uint32 + RevNo uint64 + ScopeName string + TraceContext opentracing.SpanContext + Value []byte + type DeleteMetaResult struct + Cas Cas + MutationToken MutationToken + type DeleteOptions struct + Cas Cas + CollectionName string + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + type DeleteResult struct + Cas Cas + MutationToken MutationToken + type DiagnosticInfo struct + ConfigRev int64 + MemdConns []MemdConnInfo + type DurabilityLevel uint8 + type ExistsInExCallback func(*ExistsInResult, error) + type ExistsInOptions struct + CollectionName string + Flags SubdocFlag + Key []byte + Path string + ScopeName string + TraceContext opentracing.SpanContext + type ExistsInResult struct + Cas Cas + type FailoverEntry struct + SeqNo SeqNo + VbUuid VbUuid + type GetAndLockExCallback func(*GetAndLockResult, error) + type GetAndLockOptions struct + CollectionName string + Key []byte + LockTime uint32 + ScopeName string + TraceContext opentracing.SpanContext + type GetAndLockResult struct + Cas Cas + Datatype uint8 + Flags uint32 + Value []byte + type GetAndTouchExCallback func(*GetAndTouchResult, error) + type GetAndTouchOptions struct + CollectionName string + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + type GetAndTouchResult struct + Cas Cas + Datatype uint8 + Flags uint32 + Value []byte + type GetCollectionIDOptions struct + TraceContext opentracing.SpanContext + type GetExCallback func(*GetResult, error) + type GetFailoverLogCallback func([]FailoverEntry, error) + type GetInExCallback func(*GetInResult, error) + type GetInOptions struct + CollectionName string + Flags SubdocFlag + Key []byte + Path string + ScopeName string + TraceContext opentracing.SpanContext + type GetInResult struct + Cas Cas + Value []byte + type GetMetaExCallback func(*GetMetaResult, error) + type GetMetaOptions struct + CollectionName string + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + type GetMetaResult struct + Cas Cas + Datatype uint8 + Deleted uint32 + Expiry uint32 + Flags uint32 + SeqNo SeqNo + Value []byte + type GetOptions struct + CollectionName string + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + type GetRandomExCallback func(*GetRandomResult, error) + type GetRandomOptions struct + TraceContext opentracing.SpanContext + type GetRandomResult struct + Cas Cas + Datatype uint8 + Flags uint32 + Key []byte + Value []byte + type GetReplicaExCallback func(*GetReplicaResult, error) + type GetReplicaOptions struct + CollectionName string + Key []byte + ReplicaIdx int + ScopeName string + TraceContext opentracing.SpanContext + type GetReplicaResult struct + Cas Cas + Datatype uint8 + Flags uint32 + Value []byte + type GetResult struct + Cas Cas + Datatype uint8 + Flags uint32 + Value []byte + type GetVBucketSeqnosCallback func([]VbSeqNoEntry, error) + type HelloFeature uint16 + type HttpRequest struct + Body []byte + ContentType string + Context context.Context + Endpoint string + Headers map[string]string + Method string + Password string + Path string + Service ServiceType + Username string + type HttpResponse struct + Body io.ReadCloser + Endpoint string + StatusCode int + type KeyState uint8 + type KvError struct + Code StatusCode + Context string + Description string + Name string + Opaque uint32 + Ref string + func (e KvError) Error() string + func (e KvError) Temporary() bool + type LogLevel int + const LogDebug + const LogError + const LogInfo + const LogMaxVerbosity + const LogSched + const LogTrace + const LogWarn + type LogRedactLevel int + const RedactFull + const RedactNone + const RedactPartial + type Logger interface + Log func(level LogLevel, offset int, format string, v ...interface{}) error + func DefaultStdioLogger() Logger + func VerboseStdioLogger() Logger + type LookupInExCallback func(*LookupInResult, error) + type LookupInOptions struct + CollectionName string + Flags SubdocDocFlag + Key []byte + Ops []SubDocOp + ScopeName string + TraceContext opentracing.SpanContext + type LookupInResult struct + Cas Cas + Ops []SubDocResult + type Manifest struct + Scopes []ManifestScope + UID uint64 + func (item *Manifest) UnmarshalJSON(data []byte) error + type ManifestCallback func(manifest []byte, err error) + type ManifestCollection struct + Name string + UID uint32 + func (item *ManifestCollection) UnmarshalJSON(data []byte) error + type ManifestScope struct + Collections []ManifestCollection + Name string + UID uint32 + func (item *ManifestScope) UnmarshalJSON(data []byte) error + type MemdConnInfo struct + LastActivity time.Time + LocalAddr string + RemoteAddr string + type MultiError struct + Errors []error + func (e *MultiError) Error() string + type MutateInExCallback func(*MutateInResult, error) + type MutateInOptions struct + Cas Cas + CollectionName string + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Flags SubdocDocFlag + Key []byte + Ops []SubDocOp + ScopeName string + TraceContext opentracing.SpanContext + type MutateInResult struct + Cas Cas + MutationToken MutationToken + Ops []SubDocResult + type MutationToken struct + SeqNo SeqNo + VbId uint16 + VbUuid VbUuid + type ObserveExCallback func(*ObserveResult, error) + type ObserveOptions struct + CollectionName string + Key []byte + ReplicaIdx int + ScopeName string + TraceContext opentracing.SpanContext + type ObserveResult struct + Cas Cas + KeyState KeyState + type ObserveVbExCallback func(*ObserveVbResult, error) + type ObserveVbOptions struct + ReplicaIdx int + TraceContext opentracing.SpanContext + VbId uint16 + VbUuid VbUuid + type ObserveVbResult struct + CurrentSeqNo SeqNo + DidFailover bool + LastSeqNo SeqNo + OldVbUuid VbUuid + PersistSeqNo SeqNo + VbId uint16 + VbUuid VbUuid + type OpenStreamCallback func([]FailoverEntry, error) + type PasswordAuthProvider struct + Password string + Username string + func (auth *PasswordAuthProvider) Credentials(req AuthCredsRequest) ([]UserPassPair, error) + type PendingOp interface + Cancel func() bool + type PingKvExCallback func(*PingKvResult, error) + type PingKvOptions struct + TraceContext opentracing.SpanContext + type PingKvResult struct + Services []PingResult + type PingResult struct + Endpoint string + Error error + Latency time.Duration + type ReplaceOptions struct + Cas Cas + CollectionName string + Datatype uint8 + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Flags uint32 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + Value []byte + type SeqNo uint64 + type ServiceType int + type SetMetaExCallback func(*SetMetaResult, error) + type SetMetaOption uint32 + type SetMetaOptions struct + Cas Cas + CollectionName string + Datatype uint8 + Expiry uint32 + Extra []byte + Flags uint32 + Key []byte + Options uint32 + RevNo uint64 + ScopeName string + TraceContext opentracing.SpanContext + Value []byte + type SetMetaResult struct + Cas Cas + MutationToken MutationToken + type SetOptions struct + CollectionName string + Datatype uint8 + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Flags uint32 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + Value []byte + type SingleServerStats struct + Error error + Stats map[string]string + type SnapshotState uint32 + func (s SnapshotState) HasInMemory() bool + func (s SnapshotState) HasOnDisk() bool + type StatsExCallback func(*StatsResult, error) + type StatsOptions struct + Key string + TraceContext opentracing.SpanContext + type StatsResult struct + Servers map[string]SingleServerStats + type StatusCode uint16 + type StoreExCallback func(*StoreResult, error) + type StoreInExCallback func(*StoreInResult, error) + type StoreInOptions struct + Cas Cas + CollectionName string + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Flags SubdocFlag + Key []byte + Path string + ScopeName string + TraceContext opentracing.SpanContext + Value []byte + type StoreInResult struct + Cas Cas + MutationToken MutationToken + type StoreResult struct + Cas Cas + MutationToken MutationToken + type StreamEventCode uint32 + type StreamFilter struct + Collections []uint32 + ManifestUid uint64 + Scope uint32 + StreamId uint16 + func NewStreamFilter() *StreamFilter + type StreamObserver interface + CreateCollection func(seqNo uint64, version uint8, vbId uint16, manifestUid uint64, scopeId uint32, ...) + CreateScope func(seqNo uint64, version uint8, vbId uint16, manifestUid uint64, scopeId uint32, ...) + DeleteCollection func(seqNo uint64, version uint8, vbId uint16, manifestUid uint64, scopeId uint32, ...) + DeleteScope func(seqNo uint64, version uint8, vbId uint16, manifestUid uint64, scopeId uint32, ...) + Deletion func(seqNo, revNo, cas uint64, datatype uint8, vbId uint16, collectionId uint32, ...) + End func(vbId uint16, streamId uint16, err error) + Expiration func(seqNo, revNo, cas uint64, vbId uint16, collectionId uint32, streamId uint16, ...) + FlushCollection func(seqNo uint64, version uint8, vbId uint16, manifestUid uint64, ...) + ModifyCollection func(seqNo uint64, version uint8, vbId uint16, manifestUid uint64, ...) + Mutation func(seqNo, revNo uint64, flags, expiry, lockTime uint32, cas uint64, ...) + SnapshotMarker func(startSeqNo, endSeqNo uint64, vbId uint16, streamId uint16, ...) + type SubDocMutateError struct + Err error + OpIndex int + func (e SubDocMutateError) Error() string + type SubDocOp struct + Flags SubdocFlag + Op SubDocOpType + Path string + Value []byte + type SubDocOpType uint8 + type SubDocResult struct + Err error + Value []byte + type SubdocDocFlag uint8 + type SubdocFlag uint8 + type TouchExCallback func(*TouchResult, error) + type TouchOptions struct + Cas Cas + CollectionName string + DurabilityLevel DurabilityLevel + DurabilityLevelTimeout uint16 + Expiry uint32 + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + type TouchResult struct + Cas Cas + MutationToken MutationToken + type UnlockExCallback func(*UnlockResult, error) + type UnlockOptions struct + Cas Cas + CollectionName string + Key []byte + ScopeName string + TraceContext opentracing.SpanContext + type UnlockResult struct + Cas Cas + MutationToken MutationToken + type UserPassPair struct + Password string + Username string + type VbSeqNoEntry struct + SeqNo SeqNo + VbId uint16 + type VbUuid uint64 + type VbucketState uint32 Other modules containing this package github.com/chvck/gocbcore
Go to main page