gocbcore

package module

Go to main page

Versions in this module

v8

v8.0.5

Apr 21, 2020

v8.0.4

Mar 17, 2020

Changes in this version

type AnalyticsQueryOptions

+ TraceContext RequestSpanContext

+ type BackoffCalculator func(retryAttempts uint32) time.Duration

+ func ExponentialBackoff(min, max time.Duration, backoffFactor float64) BackoffCalculator

type HTTPRequest

+ TraceContext RequestSpanContext

type KeyValueError

+ LastConnectionID string

+ LastDispatchedFrom string

+ LastDispatchedTo string

type N1QLQueryOptions

+ TraceContext RequestSpanContext

type SearchQueryOptions

+ TraceContext RequestSpanContext

type ViewQueryOptions

+ TraceContext RequestSpanContext

v8.0.3

Feb 21, 2020

v8.0.2

Feb 19, 2020

Changes in this version

+ var ErrDCPBackfillFailed = makeStreamEndStatusError(streamEndBackfillFailed)

type N1QLRowReader

+ func (q N1QLRowReader) PreparedName() (string, error)

v8.0.1

Jan 22, 2020

v8.0.0

Jan 20, 2020

Changes in this version

+ const BinaryType

+ const CapiService

+ const CbasService

+ const ClusterCapabilityEnhancedPreparedStatements

+ const DatatypeFlagCompressed

+ const DatatypeFlagJSON

+ const DatatypeFlagXattrs

+ const DcpAgentPriorityHigh

+ const DcpAgentPriorityLow

+ const DcpAgentPriorityMed

+ const DcpOpenFlagIncludeXattrs

+ const DcpOpenFlagNoValue

+ const DcpOpenFlagNotifier

+ const DcpOpenFlagProducer

+ const DcpStreamAddFlagActiveOnly

+ const DcpStreamAddFlagDiskOnly

+ 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 PlainAuthMechanism

+ const RegenerateCas

+ const ScramSha1AuthMechanism

+ const ScramSha256AuthMechanism

+ const ScramSha512AuthMechanism

+ 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 StatusSyncWriteReCommitInProgress

+ 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 SubdocDocFlagAddDoc

+ const SubdocDocFlagMkDoc

+ const SubdocDocFlagNone

+ const SubdocFlagExpandMacros

+ const SubdocFlagMkDirP

+ const SubdocFlagNone

+ const SubdocFlagXattrPath

+ const UnknownCompression

+ const UnknownType

+ const UseLwwConflictResolution

+ const VbucketStateActive

+ const VbucketStateDead

+ const VbucketStatePending

+ const VbucketStateReplica

+ var AnalyticsTemporaryFailureRetryReason = retryReason

+ var CircuitBreakerOpenRetryReason = retryReason

+ var ErrAmbiguousTimeout = &dwError

+ var ErrAuthenticationFailure = errors.New("authentication failure")

+ var ErrBadHosts = errors.New("failed to connect to any of the specified hosts")

+ var ErrBucketAlreadySelected = errors.New("bucket already selected")

+ var ErrBucketExists = errors.New("bucket exists")

+ var ErrBucketNotFlushable = errors.New("bucket not flushable")

+ var ErrBucketNotFound = errors.New("bucket not found")

+ var ErrCasMismatch = errors.New("cas mismatch")

+ var ErrCliInternalError = errors.New("client internal error")

+ var ErrCollectionExists = errors.New("collection exists")

+ var ErrCollectionNotFound = errors.New("collection not found")

+ var ErrCollectionsUnsupported = errors.New("collections are not enabled")

+ var ErrCompilationFailure = errors.New("compilation failure")

+ var ErrDCPStreamClosed = makeStreamEndStatusError(streamEndClosed)

+ var ErrDCPStreamDisconnected = makeStreamEndStatusError(streamEndDisconnected)

+ var ErrDCPStreamFilterEmpty = makeStreamEndStatusError(streamEndFilterEmpty)

+ var ErrDCPStreamStateChanged = makeStreamEndStatusError(streamEndStateChanged)

+ var ErrDCPStreamTooSlow = makeStreamEndStatusError(streamEndTooSlow)

+ var ErrDatasetExists = errors.New("dataset exists")

+ var ErrDatasetNotFound = errors.New("dataset not found")

+ var ErrDataverseExists = errors.New("dataverse exists")

+ var ErrDataverseNotFound = errors.New("dataverse not found")

+ var ErrDecodingFailure = errors.New("decoding failure")

+ var ErrDeltaInvalid = errors.New("delta invalid")

+ var ErrDesignDocumentNotFound = errors.New("design document not found")

+ var ErrDocumentExists = errors.New("document exists")

+ var ErrDocumentLocked = errors.New("document locked")

+ var ErrDocumentNotFound = errors.New("document not found")

+ var ErrDocumentNotJSON = errors.New("document not json")

+ var ErrDocumentUnretrievable = errors.New("document unretrievable")

+ var ErrDurabilityAmbiguous = errors.New("durability ambiguous")

+ var ErrDurabilityImpossible = errors.New("durability impossible")

+ var ErrDurabilityLevelNotAvailable = errors.New("durability level not available")

+ var ErrDurableWriteInProgress = errors.New("durable write in progress")

+ var ErrDurableWriteReCommitInProgress = errors.New("durable write recommit in progress")

+ var ErrEncodingFailure = errors.New("encoding failure")

+ var ErrFeatureNotAvailable = errors.New("feature is not available")

+ var ErrGroupNotFound = errors.New("group not found")

+ var ErrIndexExists = errors.New("index exists")

+ var ErrIndexFailure = errors.New("index failure")

+ var ErrIndexNotFound = errors.New("index not found")

+ var ErrInternalServerFailure = errors.New("internal server failure")

+ var ErrInvalidArgument = errors.New("invalid argument")

+ var ErrInvalidCertificate = 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")

+ var ErrInvalidVBucket = errors.New("specific vbucket index is invalid")

+ var ErrJobQueueFull = errors.New("job queue full")

+ var ErrLinkNotFound = errors.New("link not found")

+ var ErrMemdAccessError = makeKvStatusError(StatusAccessError)

+ var ErrMemdAuthContinue = makeKvStatusError(StatusAuthContinue)

+ var ErrMemdAuthError = makeKvStatusError(StatusAuthError)

+ var ErrMemdAuthStale = makeKvStatusError(StatusAuthStale)

+ var ErrMemdBadDelta = makeKvStatusError(StatusBadDelta)

+ var ErrMemdBusy = makeKvStatusError(StatusBusy)

+ var ErrMemdCollectionNotFound = makeKvStatusError(StatusCollectionUnknown)

+ var ErrMemdDurabilityImpossible = makeKvStatusError(StatusDurabilityImpossible)

+ var ErrMemdDurabilityInvalidLevel = makeKvStatusError(StatusDurabilityInvalidLevel)

+ var ErrMemdInternalError = makeKvStatusError(StatusInternalError)

+ var ErrMemdInvalidArgs = makeKvStatusError(StatusInvalidArgs)

+ var ErrMemdKeyExists = makeKvStatusError(StatusKeyExists)

+ var ErrMemdKeyNotFound = makeKvStatusError(StatusKeyNotFound)

+ var ErrMemdLocked = makeKvStatusError(StatusLocked)

+ var ErrMemdNoBucket = makeKvStatusError(StatusNoBucket)

+ var ErrMemdNotInitialized = makeKvStatusError(StatusNotInitialized)

+ var ErrMemdNotMyVBucket = makeKvStatusError(StatusNotMyVBucket)

+ var ErrMemdNotStored = makeKvStatusError(StatusNotStored)

+ var ErrMemdNotSupported = makeKvStatusError(StatusNotSupported)

+ var ErrMemdOutOfMemory = makeKvStatusError(StatusOutOfMemory)

+ var ErrMemdRangeError = makeKvStatusError(StatusRangeError)

+ var ErrMemdRollback = makeKvStatusError(StatusRollback)

+ var ErrMemdScopeNotFound = makeKvStatusError(StatusScopeUnknown)

+ var ErrMemdSubDocBadCombo = makeKvStatusError(StatusSubDocBadCombo)

+ var ErrMemdSubDocBadDelta = makeKvStatusError(StatusSubDocBadDelta)

+ var ErrMemdSubDocBadMulti = makeKvStatusError(StatusSubDocBadMulti)

+ var ErrMemdSubDocBadRange = makeKvStatusError(StatusSubDocBadRange)

+ var ErrMemdSubDocCantInsert = makeKvStatusError(StatusSubDocCantInsert)

+ var ErrMemdSubDocDocTooDeep = makeKvStatusError(StatusSubDocDocTooDeep)

+ var ErrMemdSubDocMultiPathFailureDeleted = makeKvStatusError(StatusSubDocMultiPathFailureDeleted)

+ var ErrMemdSubDocNotJSON = makeKvStatusError(StatusSubDocNotJSON)

+ var ErrMemdSubDocPathExists = makeKvStatusError(StatusSubDocPathExists)

+ var ErrMemdSubDocPathInvalid = makeKvStatusError(StatusSubDocPathInvalid)

+ var ErrMemdSubDocPathMismatch = makeKvStatusError(StatusSubDocPathMismatch)

+ var ErrMemdSubDocPathNotFound = makeKvStatusError(StatusSubDocPathNotFound)

+ var ErrMemdSubDocPathTooBig = makeKvStatusError(StatusSubDocPathTooBig)

+ var ErrMemdSubDocSuccessDeleted = makeKvStatusError(StatusSubDocSuccessDeleted)

+ var ErrMemdSubDocValueTooDeep = makeKvStatusError(StatusSubDocValueTooDeep)

+ var ErrMemdSubDocXattrCannotModifyVAttr = makeKvStatusError(StatusSubDocXattrCannotModifyVAttr)

+ var ErrMemdSubDocXattrInvalidFlagCombo = makeKvStatusError(StatusSubDocXattrInvalidFlagCombo)

+ var ErrMemdSubDocXattrInvalidKeyCombo = makeKvStatusError(StatusSubDocXattrInvalidKeyCombo)

+ var ErrMemdSubDocXattrUnknownMacro = makeKvStatusError(StatusSubDocXattrUnknownMacro)

+ var ErrMemdSubDocXattrUnknownVAttr = makeKvStatusError(StatusSubDocXattrUnknownVAttr)

+ var ErrMemdSyncWriteAmbiguous = makeKvStatusError(StatusSyncWriteAmbiguous)

+ var ErrMemdSyncWriteInProgess = makeKvStatusError(StatusSyncWriteInProgress)

+ var ErrMemdSyncWriteReCommitInProgress = makeKvStatusError(StatusSyncWriteReCommitInProgress)

+ var ErrMemdTmpFail = makeKvStatusError(StatusTmpFail)

+ var ErrMemdTooBig = makeKvStatusError(StatusTooBig)

+ var ErrMemdUnknownCommand = makeKvStatusError(StatusUnknownCommand)

+ var ErrMutationLost = errors.New("mutation lost")

+ var ErrNoReplicas = errors.New("no replicas responded in time")

+ var ErrNoSupportedMechanisms = errors.New("no supported authentication mechanisms")

+ var ErrNumberTooBig = errors.New("number too big")

+ var ErrOverload = errors.New("queue overflowed")

+ var ErrParsingFailure = errors.New("parsing failure")

+ var ErrPathExists = errors.New("path exists")

+ var ErrPathInvalid = errors.New("path invalid")

+ var ErrPathMismatch = errors.New("path mismatch")

+ var ErrPathNotFound = errors.New("path not found")

+ var ErrPathTooBig = errors.New("path too big")

+ var ErrPathTooDeep = errors.New("path too deep")

+ var ErrPlanningFailure = errors.New("planning failure")

+ var ErrPreparedStatementFailure = errors.New("prepared statement failure")

+ var ErrProtocol = errors.New("failed to parse server response")

+ var ErrRequestCanceled = errors.New("request canceled")

+ var ErrScopeExists = errors.New("scope exists")

+ var ErrScopeNotFound = errors.New("scope not found")

+ var ErrServiceNotAvailable = errors.New("service not available")

+ var ErrShutdown = errors.New("connection shut down")

+ var ErrSocketClosed = io.EOF

+ var ErrTemporaryFailure = errors.New("temporary failure")

+ var ErrTimeout = errors.New("operation has timed out")

+ var ErrUnambiguousTimeout = &dwError

+ var ErrUnsupportedOperation = errors.New("unsupported operation")

+ var ErrUserExists = errors.New("user exists")

+ var ErrUserNotFound = errors.New("user not found")

+ var ErrValueInvalid = errors.New("value invalid")

+ var ErrValueNotJSON = errors.New("value not json")

+ var ErrValueTooDeep = errors.New("value too deep")

+ var ErrValueTooLarge = errors.New("value too large")

+ var ErrViewNotFound = errors.New("view not found")

+ var ErrXattrCannotModifyVirtualAttribute = errors.New("xattr cannot modify virtual attribute")

+ var ErrXattrInvalidFlagCombo = errors.New("xattr invalid flag combination")

+ var ErrXattrInvalidKeyCombo = errors.New("xattr invalid key combination")

+ var ErrXattrInvalidOrder = errors.New("xattr invalid order")

+ var ErrXattrUnknownMacro = errors.New("xattr unknown macro")

+ var ErrXattrUnknownVirtualAttribute = errors.New("xattr unknown virtual attribute")

+ var KVCollectionOutdatedRetryReason = retryReason

+ var KVErrMapRetryReason = retryReason

+ var KVLockedRetryReason = retryReason

+ var KVNotMyVBucketRetryReason = retryReason

+ var KVSyncWriteInProgressRetryReason = retryReason

+ var KVSyncWriteRecommitInProgressRetryReason = retryReason

+ var KVTemporaryFailureRetryReason = retryReason

+ var NodeNotAvailableRetryReason = retryReason

+ var PipelineOverloadedRetryReason = retryReason

+ var QueryIndexNotFoundRetryReason = retryReason

+ var QueryPreparedStatementFailureRetryReason = retryReason

+ var SearchTooManyRequestsRetryReason = retryReason

+ var ServiceNotAvailableRetryReason = retryReason

+ var ServiceResponseCodeIndicatedRetryReason = retryReason

+ var SocketCloseInFlightRetryReason = retryReason

+ var SocketNotAvailableRetryReason = retryReason

+ var UnknownRetryReason = retryReason

+ func AcquireTimer(d time.Duration) *time.Timer

+ func ControlledBackoff(retryAttempts uint32) time.Duration

+ func DecodeCommonFlags(flags uint32) (DataType, CompressionType)

+ func EncodeCommonFlags(valueType DataType, compression CompressionType) uint32

+ func ReleaseTimer(t *time.Timer, wasRead bool)

+ 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

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type AdjoinExCallback func(*AdjoinResult, error)

+ type AdjoinOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type AdjoinResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type Agent struct

+ func CreateAgent(config *AgentConfig) (*Agent, error)

+ func CreateDcpAgent(config *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) AnalyticsQuery(opts AnalyticsQueryOptions) (*AnalyticsRowReader, 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(opts GetCollectionManifestOptions, 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) GetOneReplicaEx(opts GetOneReplicaOptions, cb GetReplicaExCallback) (PendingOp, error)

+ func (agent *Agent) GetRandomEx(opts GetRandomOptions, cb GetRandomExCallback) (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) HTTPClient() *http.Client

+ func (agent *Agent) HasCollectionsSupport() bool

+ 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) MaybeRetryRequest(req RetryRequest, reason RetryReason) (bool, time.Time)

+ func (agent *Agent) MgmtEps() []string

+ func (agent *Agent) MutateInEx(opts MutateInOptions, cb MutateInExCallback) (PendingOp, error)

+ func (agent *Agent) N1QLQuery(opts N1QLQueryOptions) (*N1QLRowReader, 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) SearchQuery(opts SearchQueryOptions) (*SearchRowReader, error)

+ func (agent *Agent) SelectBucket(bucketName string, deadline time.Time) 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) SupportsClusterCapability(capability ClusterCapability) bool

+ func (agent *Agent) TouchEx(opts TouchOptions, cb TouchExCallback) (PendingOp, error)

+ func (agent *Agent) UnlockEx(opts UnlockOptions, cb UnlockExCallback) (PendingOp, error)

+ func (agent *Agent) UsingGCCCP() bool

+ func (agent *Agent) VbucketToServer(vbID uint16, replicaIdx uint32) int

+ func (agent *Agent) VbucketsOnServer(index int) []uint16

+ func (agent *Agent) ViewQuery(opts ViewQueryOptions) (*ViewQueryRowReader, error)

+ type AgentConfig struct

+ Auth AuthProvider

+ BucketName string

+ CccpMaxWait time.Duration

+ CccpPollPeriod time.Duration

+ CircuitBreakerConfig CircuitBreakerConfig

+ CompressionMinRatio float64

+ CompressionMinSize int

+ ConnectTimeout time.Duration

+ DcpAgentPriority DcpAgentPriority

+ DefaultRetryStrategy RetryStrategy

+ DisableDecompression bool

+ HTTPAddrs []string

+ HTTPIdleConnectionTimeout time.Duration

+ HTTPMaxIdleConns int

+ HTTPMaxIdleConnsPerHost int

+ HTTPRedialPeriod time.Duration

+ HTTPRetryDelay time.Duration

+ KVConnectTimeout time.Duration

+ KvPoolSize int

+ MaxQueueSize int

+ MemdAddrs []string

+ NetworkType string

+ NoRootTraceSpans bool

+ TLSRootCAs *x509.CertPool

+ TLSSkipVerify bool

+ Tracer RequestTracer

+ UseCollections bool

+ UseCompression bool

+ UseDCPExpiry bool

+ UseDCPStreamID bool

+ UseDurations bool

+ UseMutationTokens bool

+ UseTLS bool

+ UseZombieLogger bool

+ UserAgent string

+ ZombieLoggerInterval time.Duration

+ ZombieLoggerSampleSize int

+ func (config *AgentConfig) FromConnStr(connStr string) error

+ type AnalyticsError struct

+ ClientContextID string

+ Endpoint string

+ Errors []AnalyticsErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ Statement string

+ func (e AnalyticsError) Error() string

+ func (e AnalyticsError) Unwrap() error

+ type AnalyticsErrorDesc struct

+ Code uint32

+ Message string

+ type AnalyticsQueryOptions struct

+ Deadline time.Time

+ Payload []byte

+ Priority int

+ RetryStrategy RetryStrategy

+ type AnalyticsRowReader struct

+ func (q *AnalyticsRowReader) Close() error

+ func (q *AnalyticsRowReader) MetaData() ([]byte, error)

+ func (q *AnalyticsRowReader) NextRow() []byte

+ func (q AnalyticsRowReader) Err() error

+ type AuthCertRequest struct

+ Endpoint string

+ Service ServiceType

+ type AuthClient interface

+ Address func() string

+ SaslAuth func(k, v []byte, deadline time.Time, cb func(b []byte, err error)) error

+ SaslListMechs func(deadline time.Time, cb func(mechs []AuthMechanism, err error)) error

+ SaslStep func(k, v []byte, deadline time.Time, cb func(err error)) error

+ SupportsFeature func(feature HelloFeature) bool

+ type AuthCredsRequest struct

+ Endpoint string

+ Service ServiceType

+ type AuthFunc func(client AuthClient, deadline time.Time, continueCb func(), ...) error

+ type AuthMechanism string

+ type AuthProvider interface

+ Certificate func(req AuthCertRequest) (*tls.Certificate, error)

+ Credentials func(req AuthCredsRequest) ([]UserPassPair, error)

+ SupportsNonTLS func() bool

+ SupportsTLS func() bool

+ type BestEffortRetryStrategy struct

+ func NewBestEffortRetryStrategy(calculator func(retryAttempts uint32) time.Duration) *BestEffortRetryStrategy

+ func (rs *BestEffortRetryStrategy) RetryAfter(req RetryRequest, reason RetryReason) RetryAction

+ type BytesAndError struct

+ Bytes []byte

+ Err error

+ type Cas uint64

+ type CircuitBreakerCallback func(error) bool

+ type CircuitBreakerConfig struct

+ CanaryTimeout time.Duration

+ CompletionCallback CircuitBreakerCallback

+ Enabled bool

+ ErrorThresholdPercentage float64

+ RollingWindow time.Duration

+ SleepWindow time.Duration

+ VolumeThreshold int64

+ type CloseStreamCallback func(error)

+ type ClusterCapability uint32

+ 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

+ CollectionID uint32

+ CollectionName string

+ Delta uint64

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Initial uint64

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ 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

+ CollectionID uint32

+ CollectionName string

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type DeleteInResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type DeleteMetaExCallback func(*DeleteMetaResult, error)

+ type DeleteMetaOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Expiry uint32

+ Extra []byte

+ Flags uint32

+ Key []byte

+ Options uint32

+ RetryStrategy RetryStrategy

+ RevNo uint64

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type DeleteMetaResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type DeleteOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type DeleteResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type DiagnosticInfo struct

+ ConfigRev int64

+ MemdConns []MemdConnInfo

+ type DurabilityLevel uint8

+ type ExecHelloResponse struct

+ Err error

+ SrvFeatures []HelloFeature

+ type ExistsInExCallback func(*ExistsInResult, error)

+ type ExistsInOptions struct

+ CollectionID uint32

+ CollectionName string

+ Flags SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type ExistsInResult struct

+ Cas Cas

+ type FailoverEntry struct

+ SeqNo SeqNo

+ VbUUID VbUUID

+ type GetAndLockExCallback func(*GetAndLockResult, error)

+ type GetAndLockOptions struct

+ CollectionID uint32

+ CollectionName string

+ Key []byte

+ LockTime uint32

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetAndLockResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetAndTouchExCallback func(*GetAndTouchResult, error)

+ type GetAndTouchOptions struct

+ CollectionID uint32

+ CollectionName string

+ Expiry uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetAndTouchResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetAnyReplicaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetCollectionIDOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetCollectionManifestOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetExCallback func(*GetResult, error)

+ type GetFailoverLogCallback func([]FailoverEntry, error)

+ type GetInExCallback func(*GetInResult, error)

+ type GetInOptions struct

+ CollectionID uint32

+ CollectionName string

+ Flags SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetInResult struct

+ Cas Cas

+ Value []byte

+ type GetMetaExCallback func(*GetMetaResult, error)

+ type GetMetaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetMetaResult struct

+ Cas Cas

+ Datatype uint8

+ Deleted uint32

+ Expiry uint32

+ Flags uint32

+ SeqNo SeqNo

+ Value []byte

+ type GetOneReplicaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Key []byte

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetOptions struct

+ CollectionID uint32

+ CollectionName string

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetRandomExCallback func(*GetRandomResult, error)

+ type GetRandomOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetRandomResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Key []byte

+ Value []byte

+ type GetReplicaExCallback func(*GetReplicaResult, error)

+ 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 HTTPError struct

+ Endpoint string

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ UniqueID string

+ func (e HTTPError) Error() string

+ func (e HTTPError) Unwrap() error

+ type HTTPRequest struct

+ Body []byte

+ ContentType string

+ Endpoint string

+ Headers map[string]string

+ IsIdempotent bool

+ Method string

+ Password string

+ Path string

+ RetryStrategy RetryStrategy

+ Service ServiceType

+ Timeout time.Duration

+ UniqueID string

+ Username string

+ type HTTPResponse struct

+ Body io.ReadCloser

+ Endpoint string

+ StatusCode int

+ type HelloFeature uint16

+ type KeyState uint8

+ type KeyValueError struct

+ BucketName string

+ CollectionID uint32

+ CollectionName string

+ Context string

+ ErrorDescription string

+ ErrorName string

+ InnerError error

+ Opaque uint32

+ Ref string

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ ScopeName string

+ StatusCode StatusCode

+ func (e KeyValueError) Error() string

+ func (e KeyValueError) Unwrap() error

+ 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

+ CollectionID uint32

+ CollectionName string

+ Flags SubdocDocFlag

+ Key []byte

+ Ops []SubDocOp

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ 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

+ ID string

+ LastActivity time.Time

+ LocalAddr string

+ RemoteAddr string

+ Scope string

+ type MutateInExCallback func(*MutateInResult, error)

+ type MutateInOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags SubdocDocFlag

+ Key []byte

+ Ops []SubDocOp

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type MutateInResult struct

+ Cas Cas

+ MutationToken MutationToken

+ Ops []SubDocResult

+ type MutationToken struct

+ SeqNo SeqNo

+ VbID uint16

+ VbUUID VbUUID

+ type N1QLError struct

+ ClientContextID string

+ Endpoint string

+ Errors []N1QLErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ Statement string

+ func (e N1QLError) Error() string

+ func (e N1QLError) Unwrap() error

+ type N1QLErrorDesc struct

+ Code uint32

+ Message string

+ type N1QLQueryOptions struct

+ Deadline time.Time

+ Payload []byte

+ RetryStrategy RetryStrategy

+ type N1QLRowReader struct

+ func (q *N1QLRowReader) Close() error

+ func (q *N1QLRowReader) MetaData() ([]byte, error)

+ func (q *N1QLRowReader) NextRow() []byte

+ func (q N1QLRowReader) Err() error

+ type NoRetryRetryAction struct

+ func (ra *NoRetryRetryAction) Duration() time.Duration

+ type ObserveExCallback func(*ObserveResult, error)

+ type ObserveOptions struct

+ CollectionID uint32

+ CollectionName string

+ Key []byte

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type ObserveResult struct

+ Cas Cas

+ KeyState KeyState

+ type ObserveVbExCallback func(*ObserveVbResult, error)

+ type ObserveVbOptions struct

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ 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) Certificate(req AuthCertRequest) (*tls.Certificate, error)

+ func (auth *PasswordAuthProvider) Credentials(req AuthCredsRequest) ([]UserPassPair, error)

+ func (auth *PasswordAuthProvider) SupportsNonTLS() bool

+ func (auth *PasswordAuthProvider) SupportsTLS() bool

+ type PendingOp interface

+ Cancel func(err error)

+ type PingKvExCallback func(*PingKvResult, error)

+ type PingKvOptions struct

+ TraceContext RequestSpanContext

+ type PingKvResult struct

+ ConfigRev int64

+ Services []PingResult

+ type PingResult struct

+ Endpoint string

+ Error error

+ ID string

+ Latency time.Duration

+ Scope string

+ type ReplaceOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type RequestSpan interface

+ Context func() RequestSpanContext

+ Finish func()

+ SetTag func(key string, value interface{}) RequestSpan

+ type RequestSpanContext interface

+ type RequestTracer interface

+ StartSpan func(operationName string, parentContext RequestSpanContext) RequestSpan

+ type RetryAction interface

+ Duration func() time.Duration

+ type RetryReason interface

+ AllowsNonIdempotentRetry func() bool

+ AlwaysRetry func() bool

+ Description func() string

+ type RetryRequest interface

+ Idempotent func() bool

+ Identifier func() string

+ RetryAttempts func() uint32

+ RetryReasons func() []RetryReason

+ type RetryStrategy interface

+ RetryAfter func(req RetryRequest, reason RetryReason) RetryAction

+ type SaslListMechsCompleted struct

+ Err error

+ Mechs []AuthMechanism

+ type SearchError struct

+ Endpoint string

+ ErrorText string

+ HTTPResponseCode int

+ IndexName string

+ InnerError error

+ Query interface{}

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ func (e SearchError) Error() string

+ func (e SearchError) Unwrap() error

+ type SearchQueryOptions struct

+ Deadline time.Time

+ IndexName string

+ Payload []byte

+ RetryStrategy RetryStrategy

+ type SearchRowReader struct

+ func (q *SearchRowReader) Close() error

+ func (q *SearchRowReader) MetaData() ([]byte, error)

+ func (q *SearchRowReader) NextRow() []byte

+ func (q SearchRowReader) Err() error

+ type SeqNo uint64

+ type ServiceType int

+ type SetMetaExCallback func(*SetMetaResult, error)

+ type SetMetaOption uint32

+ type SetMetaOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Expiry uint32

+ Extra []byte

+ Flags uint32

+ Key []byte

+ Options uint32

+ RetryStrategy RetryStrategy

+ RevNo uint64

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type SetMetaResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type SetOptions struct

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ 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

+ RetryStrategy RetryStrategy

+ Target StatsTarget

+ TraceContext RequestSpanContext

+ type StatsResult struct

+ Servers map[string]SingleServerStats

+ type StatsTarget interface

+ type StatusCode uint16

+ type StoreExCallback func(*StoreResult, error)

+ type StoreInExCallback func(*StoreInResult, error)

+ type StoreInOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ DurabilityLevel DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type StoreInResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type StoreResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type StreamEndStatus uint32

+ 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 SubDocOp struct

+ Flags SubdocFlag

+ Op SubDocOpType

+ Path string

+ Value []byte

+ type SubDocOpType uint8

+ type SubDocResult struct

+ Err error

+ Value []byte

+ type SubDocumentError struct

+ Index int

+ InnerError error

+ func (err SubDocumentError) Error() string

+ func (err SubDocumentError) Unwrap() error

+ type SubdocDocFlag uint8

+ type SubdocFlag uint8

+ type TouchExCallback func(*TouchResult, error)

+ type TouchOptions struct

+ CollectionID uint32

+ CollectionName string

+ Expiry uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type TouchResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type UnlockExCallback func(*UnlockResult, error)

+ type UnlockOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type UnlockResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type UserPassPair struct

+ Password string

+ Username string

+ type VBucketIDStatsTarget struct

+ VbID uint16

+ type VbSeqNoEntry struct

+ SeqNo SeqNo

+ VbID uint16

+ type VbUUID uint64

+ type VbucketState uint32

+ type ViewError struct

+ DesignDocumentName string

+ Endpoint string

+ Errors []ViewQueryErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ ViewName string

+ func (e ViewError) Error() string

+ func (e ViewError) Unwrap() error

+ type ViewQueryErrorDesc struct

+ Message string

+ SourceNode string

+ type ViewQueryOptions struct

+ Deadline time.Time

+ DesignDocumentName string

+ Options url.Values

+ RetryStrategy RetryStrategy

+ ViewName string

+ ViewType string

+ type ViewQueryRowReader struct

+ func (q *ViewQueryRowReader) Close() error

+ func (q *ViewQueryRowReader) MetaData() ([]byte, error)

+ func (q *ViewQueryRowReader) NextRow() []byte

+ func (q ViewQueryRowReader) Err() error

+ type WithDurationRetryAction struct

+ WithDuration time.Duration

+ func (ra *WithDurationRetryAction) Duration() time.Duration

v8.0.0-beta.1

Oct 3, 2019

v8.0.0-alpha.5

Aug 8, 2019

v8.0.0-alpha.4

Jul 25, 2019

v8.0.0-alpha.3

May 14, 2019

v8.0.0-alpha.2

Apr 16, 2019

v8.0.0-alpha.1

Mar 21, 2019

Other modules containing this package

github.com/couchbase/gocbcore

github.com/couchbase/gocbcore/v10

github.com/couchbase/gocbcore/v9

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