gocbcore

package module

Go to main page

Versions in this module

v10

v10.4.1

Apr 17, 2024

v10.4.0

Mar 13, 2024

Changes in this version

type AgentGroup

+ func (ag *AgentGroup) Internal() *AgentGroupInternal

+ type AgentGroupInternal struct

+ func (agi *AgentGroupInternal) SearchCapabilityStatus(cap SearchCapability) CapabilityStatus

+ type CapabilityStatus uint32

+ const CapabilityStatusSupported

+ const CapabilityStatusUnknown

+ const CapabilityStatusUnsupported

+ type SearchCapability uint32

+ const SearchCapabilityScopedIndexes

+ const SearchCapabilityVectorSearch

v10.3.2

Feb 20, 2024

Changes in this version

type SearchQueryOptions

+ BucketName string

+ ScopeName string

v10.3.1

Jan 17, 2024

Changes in this version

+ var ErrDocumentNotLocked = errors.New("document not locked")

+ var ErrMemdNotLocked = makeKvStatusError(memd.StatusNotLocked)

type DCPConfig

+ UseChangeStreams bool

type SnapshotState

+ func (s SnapshotState) HasHistory() bool

+ func (s SnapshotState) HasMayDuplicateKeys() bool

v10.3.0

Nov 21, 2023

Changes in this version

+ var ErrMemdConfigOnly = makeKvStatusError(memd.StatusConfigOnly)

+ func EnableHttpResponseTracking()

+ func ReportLeakedHttpResponses() bool

type BucketCapability

+ const BucketCapabilityNonDedupedHistory

type DCPAgentConfig

+ EnableCCCPPoller bool

type GetAllCollectionManifestsOptions

+ User string

type GetCollectionIDOptions

+ User string

type GetCollectionManifestOptions

+ User string

type IoConfig

+ UseClusterMapNotifications bool

type ManifestCollection

+ History *bool

v10.2.12

Feb 23, 2024

v10.2.11

Jan 18, 2024

v10.2.10

Nov 21, 2023

v10.2.9

Oct 18, 2023

Changes in this version

+ var ErrCircuitBreakerOpen = errors.New("circuit breaker open")

v10.2.8

Sep 25, 2023

v10.2.7

Aug 31, 2023

v10.2.6

Jul 25, 2023

Changes in this version

type BucketCapability

+ const BucketCapabilityReplicaRead

type LookupInOptions

+ ReplicaIdx int

v10.2.5

Jun 21, 2023

Changes in this version

+ var ErrBusy = errors.New("busy")

+ var ErrConnectionIDInvalid = errors.New("connection id unknown")

type RangeScanCreateResult

+ RangeScanCancel func(opts RangeScanCancelOptions, cb RangeScanCancelCallback) (PendingOp, error)

+ RangeScanContinue func(opts RangeScanContinueOptions, dataCb RangeScanContinueDataCallback, ...) (PendingOp, error)

+ ScanUUID func() []byte

v10.2.4

May 17, 2023

v10.2.3

Apr 18, 2023

v10.2.2

Mar 22, 2023

v10.2.1

Feb 22, 2023

Changes in this version

+ var ErrMemdRangeScanCancelled = makeKvStatusError(memd.StatusRangeScanCancelled)

+ var ErrMemdRangeScanComplete = makeKvStatusError(memd.StatusRangeScanComplete)

+ var ErrMemdRangeScanMore = makeKvStatusError(memd.StatusRangeScanMore)

+ var ErrMemdRangeScanVbUUIDNotEqual = makeKvStatusError(memd.StatusRangeScanVbUUIDNotEqual)

+ var ErrRangeScanCancelled = errors.New("range scan cancelled")

+ var ErrRangeScanComplete = errors.New("range scan complete")

+ var ErrRangeScanMore = errors.New("range scan more")

+ var ErrRangeScanVbUUIDNotEqual = errors.New("range scan vb-uuid mismatch")

type Agent

+ func (agent *Agent) RangeScanCancel(scanUUID []byte, vbID uint16, opts RangeScanCancelOptions, ...) (PendingOp, error)

+ func (agent *Agent) RangeScanContinue(scanUUID []byte, vbID uint16, opts RangeScanContinueOptions, ...) (PendingOp, error)

+ func (agent *Agent) RangeScanCreate(vbID uint16, opts RangeScanCreateOptions, cb RangeScanCreateCallback) (PendingOp, error)

+ func (agent *Agent) WaitForConfigSnapshot(deadline time.Time, opts WaitForConfigSnapshotOptions, ...) (PendingOp, error)

type BucketCapability

+ const BucketCapabilityRangeScan

+ type RangeScanCancelCallback func(*RangeScanCancelResult, error)

+ type RangeScanCancelOptions struct

+ Deadline time.Time

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ User string

+ type RangeScanCancelResult struct

+ type RangeScanContinueActionCallback func(*RangeScanContinueResult, error)

+ type RangeScanContinueDataCallback func([]RangeScanItem)

+ type RangeScanContinueOptions struct

+ Deadline time.Time

+ MaxBytes uint32

+ MaxCount uint32

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ User string

+ type RangeScanContinueResult struct

+ Complete bool

+ More bool

+ type RangeScanCreateCallback func(*RangeScanCreateResult, error)

+ type RangeScanCreateOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ KeysOnly bool

+ Range *RangeScanCreateRangeScanConfig

+ RetryStrategy RetryStrategy

+ Sampling *RangeScanCreateRandomSamplingConfig

+ ScopeName string

+ Snapshot *RangeScanCreateSnapshotRequirements

+ TraceContext RequestSpanContext

+ User string

+ type RangeScanCreateRandomSamplingConfig struct

+ Samples uint64

+ Seed uint64

+ type RangeScanCreateRangeScanConfig struct

+ End []byte

+ ExclusiveEnd []byte

+ ExclusiveStart []byte

+ Start []byte

+ type RangeScanCreateResult struct

+ KeysOnly bool

+ ScanUUUID []byte

+ type RangeScanCreateSnapshotRequirements struct

+ SeqNo SeqNo

+ SeqNoExists bool

+ VbUUID VbUUID

+ type RangeScanItem struct

+ Cas Cas

+ Datatype uint8

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ SeqNo SeqNo

+ Value []byte

+ type WaitForConfigSnapshotCallback func(*WaitForConfigSnapshotResult, error)

+ type WaitForConfigSnapshotOptions struct

+ type WaitForConfigSnapshotResult struct

+ Snapshot *ConfigSnapshot

v10.2.0

Oct 20, 2022

Changes in this version

+ var CredentialsFetchFailedRetryReason = retryReason

+ var ErrNotStored = errors.New("document was not stored")

+ type SRVRecord struct

+ Host string

+ Proto string

+ Scheme string

type SeedConfig

+ SRVRecord *SRVRecord

v10.1.7

Feb 20, 2023

v10.1.6

Oct 27, 2022

v10.1.5

Sep 21, 2022

Changes in this version

type AdjoinResult

+ Internal struct{ ... }

type AgentConfig

+ InternalConfig InternalConfig

type CounterResult

+ Internal struct{ ... }

type DeleteMetaResult

+ Internal struct{ ... }

type DeleteResult

+ Internal struct{ ... }

type GetAllCollectionManifestsOptions

+ Deadline time.Time

type GetAndLockResult

+ Internal struct{ ... }

type GetAndTouchResult

+ Internal struct{ ... }

type GetCollectionIDOptions

+ Deadline time.Time

type GetCollectionIDResult

+ Internal struct{ ... }

type GetCollectionManifestOptions

+ Deadline time.Time

type GetCollectionManifestResult

+ Internal struct{ ... }

type GetMetaResult

+ Internal struct{ ... }

type GetRandomResult

+ Internal struct{ ... }

type GetReplicaResult

+ Internal struct{ ... }

type GetResult

+ Internal struct{ ... }

+ type InternalConfig struct

+ EnableResourceUnitsTrackingHello bool

type KeyValueError

+ Internal struct{ ... }

type LostTransactionCleaner

+ GetAndResetResourceUnits func() *TransactionResourceUnitResult

type MutateInResult

+ Internal struct{ ... }

type ObserveResult

+ Internal struct{ ... }

type ObserveVbResult

+ Internal struct{ ... }

+ type ResourceUnitResult struct

+ ReadUnits uint16

+ WriteUnits uint16

type ResumeTransactionOptions

+ Internal struct{ ... }

type SetMetaResult

+ Internal struct{ ... }

type StoreResult

+ Internal struct{ ... }

type TimeoutError

+ Internal struct{ ... }

type TouchResult

+ Internal struct{ ... }

type TransactionATRLocation

+ func (tlal TransactionATRLocation) String() string

type TransactionOptions

+ func (opts *TransactionOptions) String() string

+ type TransactionResourceUnitResult struct

+ NumOps uint32

+ ReadUnits uint32

+ WriteUnits uint32

type TransactionsCleaner

+ GetAndResetResourceUnits func() *TransactionResourceUnitResult

type TransactionsConfig

+ func (config *TransactionsConfig) String() string

type TransactionsManagerInternal

+ func (t *TransactionsManagerInternal) CleanupThreadGetAndResetResourceUnits() *TransactionResourceUnitResult

+ func (t *TransactionsManagerInternal) LostCleanupGetAndResetResourceUnits() *TransactionResourceUnitResult

type UnlockResult

+ Internal struct{ ... }

v10.1.4

Jul 20, 2022

Changes in this version

+ type InMemoryTransactionLogger struct

+ func NewInMemoryTransactionLogger() *InMemoryTransactionLogger

+ func (tl *InMemoryTransactionLogger) Log(level LogLevel, offset int, txnID, attemptID, fmt string, args ...interface{}) error

+ func (tl *InMemoryTransactionLogger) Logs() []TransactionLogItem

+ type NoopTransactionLogger struct

+ func NewNoopTransactionLogger() *NoopTransactionLogger

+ func (n *NoopTransactionLogger) Log(level LogLevel, offset int, txnID, attemptID, fmt string, args ...interface{}) error

+ func (n *NoopTransactionLogger) Logs() []TransactionLogItem

type ResumeTransactionOptions

+ TransactionLogger TransactionLogger

type Transaction

+ func (t *Transaction) Logger() TransactionLogger

type TransactionAttemptState

+ func (state TransactionAttemptState) String() string

type TransactionErrorReason

+ func (reason TransactionErrorReason) String() string

+ type TransactionLogItem struct

+ Level LogLevel

+ func (item TransactionLogItem) String() string

+ type TransactionLogger interface

+ Log func(level LogLevel, offset int, txnID, attemptID, format string, v ...interface{}) error

type TransactionLostATRLocation

+ func (tlal TransactionLostATRLocation) String() string

type TransactionOptions

+ TransactionLogger TransactionLogger

type TransactionUpdateStateOptions

+ func (tuso TransactionUpdateStateOptions) String() string

type TransactionsCleanupRequest

+ Age time.Duration

v10.1.3

Jun 22, 2022

Changes in this version

type HTTPConfig

+ ConnectTimeout time.Duration

type Transaction

+ func (t *Transaction) FinalErrorToRaise() TransactionErrorReason

type TransactionErrorReason

+ const TransactionErrorReasonSuccess

type TransactionOperationFailedError

+ func (tfe TransactionOperationFailedError) InternalUnwrap() error

type TransactionUpdateStateOptions

+ Reason TransactionErrorReason

v10.1.2

Apr 26, 2022

Changes in this version

type TransactionOptions

+ Internal struct{ ... }

type TransactionsManagerInternal

+ func (t *TransactionsManagerInternal) CleanupLocations() []TransactionLostATRLocation

v10.1.1

Mar 15, 2022

Changes in this version

+ var QueryErrorRetryable = retryReason

type N1QLErrorDesc

+ Reason map[string]interface{}

+ Retry bool

+ func (e N1QLErrorDesc) MarshalJSON() ([]byte, error)

v10.1.0

Feb 16, 2022

Changes in this version

+ const TransactionAttemptStateAborted

+ const TransactionAttemptStateCommitted

+ const TransactionAttemptStateCommitting

+ const TransactionAttemptStateCompleted

+ const TransactionAttemptStateNothingWritten

+ const TransactionAttemptStatePending

+ const TransactionAttemptStateRolledBack

+ const TransactionDurabilityLevelMajority

+ const TransactionDurabilityLevelMajorityAndPersistToActive

+ const TransactionDurabilityLevelNone

+ const TransactionDurabilityLevelPersistToMajority

+ const TransactionDurabilityLevelUnknown

+ const TransactionStagedMutationInsert

+ const TransactionStagedMutationRemove

+ const TransactionStagedMutationReplace

+ const TransactionStagedMutationUnknown

+ var ErrAmbiguous = errors.New("ambiguous error")

+ var ErrAtrEntryNotFound = errors.New("atr entry not found")

+ var ErrAtrFull = errors.New("atr full")

+ var ErrAtrNotFound = errors.New("atr not found")

+ var ErrAttemptExpired = errors.New("attempt expired")

+ var ErrDocAlreadyInTransaction = errors.New("doc already in transaction")

+ var ErrForwardCompatibilityFailure = errors.New("forward compatibility error")

+ var ErrHard = errors.New("hard")

+ var ErrIllegalState = errors.New("illegal State")

+ var ErrNoAttempt = errors.New("attempt was not started")

+ var ErrOther = errors.New("other error")

+ var ErrPreviousOperationFailed = errors.New("previous operation failed")

+ var ErrTransactionAbortedExternally = errors.New("transaction aborted externally")

+ var ErrTransient = errors.New("transient error")

+ var ErrWriteWriteConflict = errors.New("write write conflict")

+ func TransactionsProtocolExtensions() []string

+ func TransactionsProtocolVersion() string

+ type LostTransactionCleaner interface

+ Close func()

+ ProcessATR func(agent *Agent, oboUser string, collection, scope, atrID string, ...)

+ ProcessClient func(agent *Agent, oboUser string, collection, scope, uuid string, ...)

+ RemoveClientFromAllLocations func(uuid string) error

+ func NewLostTransactionCleaner(config *TransactionsConfig) LostTransactionCleaner

+ type ResumeTransactionOptions struct

+ BucketAgentProvider TransactionsBucketAgentProviderFn

+ type Transaction struct

+ func (t *Transaction) Attempt() TransactionAttempt

+ func (t *Transaction) CanCommit() bool

+ func (t *Transaction) Commit(cb TransactionCommitCallback) error

+ func (t *Transaction) Config() TransactionOptions

+ func (t *Transaction) Get(opts TransactionGetOptions, cb TransactionGetCallback) error

+ func (t *Transaction) GetATRLocation() TransactionATRLocation

+ func (t *Transaction) GetMutations() []TransactionStagedMutation

+ func (t *Transaction) HasExpired() bool

+ func (t *Transaction) ID() string

+ func (t *Transaction) Insert(opts TransactionInsertOptions, cb TransactionStoreCallback) error

+ func (t *Transaction) NewAttempt() error

+ func (t *Transaction) Remove(opts TransactionRemoveOptions, cb TransactionStoreCallback) error

+ func (t *Transaction) Replace(opts TransactionReplaceOptions, cb TransactionStoreCallback) error

+ func (t *Transaction) Rollback(cb TransactionRollbackCallback) error

+ func (t *Transaction) SerializeAttempt(cb func([]byte, error)) error

+ func (t *Transaction) SetATRLocation(location TransactionATRLocation) error

+ func (t *Transaction) ShouldRetry() bool

+ func (t *Transaction) ShouldRollback() bool

+ func (t *Transaction) TimeRemaining() time.Duration

+ func (t *Transaction) UpdateState(opts TransactionUpdateStateOptions)

+ type TransactionATRLocation struct

+ Agent *Agent

+ CollectionName string

+ OboUser string

+ ScopeName string

+ type TransactionAttempt struct

+ AtrBucketName string

+ AtrCollectionName string

+ AtrID []byte

+ AtrScopeName string

+ Expired bool

+ ID string

+ PreExpiryAutoRollback bool

+ State TransactionAttemptState

+ UnstagingComplete bool

+ type TransactionAttemptState int

+ type TransactionCleanUpHooks interface

+ BeforeATRGet func(id []byte, cb func(error))

+ BeforeATRRemove func(id []byte, cb func(error))

+ BeforeCommitDoc func(id []byte, cb func(error))

+ BeforeDocGet func(id []byte, cb func(error))

+ BeforeRemoveDoc func(id []byte, cb func(error))

+ BeforeRemoveDocStagedForRemoval func(id []byte, cb func(error))

+ BeforeRemoveLinks func(id []byte, cb func(error))

+ type TransactionClientRecordDetails struct

+ AtrsHandledByClient []string

+ CasNowNanos int64

+ CheckAtrEveryNMillis int

+ ClientIsNew bool

+ ClientUUID string

+ ExpiredClientIDs []string

+ IndexOfThisClient int

+ NumActiveClients int

+ NumExistingClients int

+ NumExpiredClients int

+ OverrideActive bool

+ OverrideEnabled bool

+ OverrideExpiresCas int64

+ type TransactionClientRecordHooks interface

+ BeforeCreateRecord func(cb func(error))

+ BeforeGetRecord func(cb func(error))

+ BeforeRemoveClient func(cb func(error))

+ BeforeUpdateCAS func(cb func(error))

+ BeforeUpdateRecord func(cb func(error))

+ type TransactionCommitCallback func(error)

+ type TransactionCreateGetResultOptions struct

+ Agent *Agent

+ Cas Cas

+ CollectionName string

+ Key []byte

+ Meta *TransactionMutableItemMeta

+ OboUser string

+ ScopeName string

+ type TransactionDefaultCleanupHooks struct

+ func (dh *TransactionDefaultCleanupHooks) BeforeATRGet(id []byte, cb func(error))

+ func (dh *TransactionDefaultCleanupHooks) BeforeATRRemove(id []byte, cb func(error))

+ func (dh *TransactionDefaultCleanupHooks) BeforeCommitDoc(id []byte, cb func(error))

+ func (dh *TransactionDefaultCleanupHooks) BeforeDocGet(id []byte, cb func(error))

+ func (dh *TransactionDefaultCleanupHooks) BeforeRemoveDoc(id []byte, cb func(error))

+ func (dh *TransactionDefaultCleanupHooks) BeforeRemoveDocStagedForRemoval(id []byte, cb func(error))

+ func (dh *TransactionDefaultCleanupHooks) BeforeRemoveLinks(id []byte, cb func(error))

+ type TransactionDefaultClientRecordHooks struct

+ func (dh *TransactionDefaultClientRecordHooks) BeforeCreateRecord(cb func(error))

+ func (dh *TransactionDefaultClientRecordHooks) BeforeGetRecord(cb func(error))

+ func (dh *TransactionDefaultClientRecordHooks) BeforeRemoveClient(cb func(error))

+ func (dh *TransactionDefaultClientRecordHooks) BeforeUpdateCAS(cb func(error))

+ func (dh *TransactionDefaultClientRecordHooks) BeforeUpdateRecord(cb func(error))

+ type TransactionDefaultHooks struct

+ func (dh *TransactionDefaultHooks) AfterATRAborted(cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterATRCommit(cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterATRComplete(cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterATRPending(cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterATRRolledBack(cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterDocCommitted(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterDocCommittedBeforeSavingCAS(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterDocRemovedPostRetry(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterDocRemovedPreRetry(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterDocsCommitted(cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterDocsRemoved(cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterGetComplete(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterRemoveStagedInsert(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterRollbackDeleteInserted(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterRollbackReplaceOrRemove(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterStagedInsertComplete(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterStagedRemoveComplete(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) AfterStagedReplaceComplete(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeATRAborted(cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeATRCommit(cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeATRCommitAmbiguityResolution(cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeATRComplete(cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeATRPending(cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeATRRolledBack(cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeCheckATREntryForBlockingDoc(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeDocCommitted(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeDocGet(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeDocRemoved(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeDocRolledBack(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeGetDocInExistsDuringStagedInsert(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeRemoveStagedInsert(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeRemovingDocDuringStagedInsert(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeRollbackDeleteInserted(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeStagedInsert(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeStagedRemove(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) BeforeStagedReplace(docID []byte, cb func(err error))

+ func (dh *TransactionDefaultHooks) HasExpiredClientSideHook(stage string, docID []byte, cb func(bool, error))

+ func (dh *TransactionDefaultHooks) RandomATRIDForVbucket(cb func(string, error))

+ type TransactionDurabilityLevel int

+ type TransactionErrorClass uint8

+ const TransactionErrorClassFailAmbiguous

+ const TransactionErrorClassFailCasMismatch

+ const TransactionErrorClassFailDocAlreadyExists

+ const TransactionErrorClassFailDocNotFound

+ const TransactionErrorClassFailExpiry

+ const TransactionErrorClassFailHard

+ const TransactionErrorClassFailOther

+ const TransactionErrorClassFailOutOfSpace

+ const TransactionErrorClassFailPathAlreadyExists

+ const TransactionErrorClassFailPathNotFound

+ const TransactionErrorClassFailTransient

+ const TransactionErrorClassFailWriteWriteConflict

+ type TransactionErrorReason uint8

+ const TransactionErrorReasonTransactionCommitAmbiguous

+ const TransactionErrorReasonTransactionExpired

+ const TransactionErrorReasonTransactionFailed

+ const TransactionErrorReasonTransactionFailedPostCommit

+ type TransactionForwardCompatibilityEntry struct

+ Behaviour string

+ ProtocolExtension string

+ ProtocolVersion string

+ RetryInterval int

+ type TransactionGetCallback func(*TransactionGetResult, error)

+ type TransactionGetOptions struct

+ Agent *Agent

+ CollectionName string

+ Key []byte

+ NoRYOW bool

+ OboUser string

+ ScopeName string

+ type TransactionGetResult struct

+ Cas Cas

+ Meta *TransactionMutableItemMeta

+ Value []byte

+ type TransactionHooks interface

+ AfterATRAborted func(func(err error))

+ AfterATRCommit func(func(err error))

+ AfterATRComplete func(func(err error))

+ AfterATRPending func(func(err error))

+ AfterATRRolledBack func(func(err error))

+ AfterDocCommitted func(docID []byte, cb func(err error))

+ AfterDocCommittedBeforeSavingCAS func(docID []byte, cb func(err error))

+ AfterDocRemovedPostRetry func(docID []byte, cb func(err error))

+ AfterDocRemovedPreRetry func(docID []byte, cb func(err error))

+ AfterDocsCommitted func(func(err error))

+ AfterDocsRemoved func(func(err error))

+ AfterGetComplete func(docID []byte, cb func(err error))

+ AfterRemoveStagedInsert func(docID []byte, cb func(err error))

+ AfterRollbackDeleteInserted func(docID []byte, cb func(err error))

+ AfterRollbackReplaceOrRemove func(docID []byte, cb func(err error))

+ AfterStagedInsertComplete func(docID []byte, cb func(err error))

+ AfterStagedRemoveComplete func(docID []byte, cb func(err error))

+ AfterStagedReplaceComplete func(docID []byte, cb func(err error))

+ BeforeATRAborted func(func(err error))

+ BeforeATRCommit func(func(err error))

+ BeforeATRCommitAmbiguityResolution func(func(err error))

+ BeforeATRComplete func(func(err error))

+ BeforeATRPending func(func(err error))

+ BeforeATRRolledBack func(func(err error))

+ BeforeCheckATREntryForBlockingDoc func(docID []byte, cb func(err error))

+ BeforeDocCommitted func(docID []byte, cb func(err error))

+ BeforeDocGet func(docID []byte, cb func(err error))

+ BeforeDocRemoved func(docID []byte, cb func(err error))

+ BeforeDocRolledBack func(docID []byte, cb func(err error))

+ BeforeGetDocInExistsDuringStagedInsert func(docID []byte, cb func(err error))

+ BeforeRemoveStagedInsert func(docID []byte, cb func(err error))

+ BeforeRemovingDocDuringStagedInsert func(docID []byte, cb func(err error))

+ BeforeRollbackDeleteInserted func(docID []byte, cb func(err error))

+ BeforeStagedInsert func(docID []byte, cb func(err error))

+ BeforeStagedRemove func(docID []byte, cb func(err error))

+ BeforeStagedReplace func(docID []byte, cb func(err error))

+ HasExpiredClientSideHook func(stage string, docID []byte, cb func(bool, error))

+ RandomATRIDForVbucket func(cb func(string, error))

+ type TransactionInsertOptions struct

+ Agent *Agent

+ CollectionName string

+ Key []byte

+ OboUser string

+ ScopeName string

+ Value json.RawMessage

+ type TransactionLostATRLocation struct

+ BucketName string

+ CollectionName string

+ ScopeName string

+ type TransactionMutableItemMeta struct

+ ATR TransactionMutableItemMetaATR

+ AttemptID string

+ ForwardCompat map[string][]TransactionForwardCompatibilityEntry

+ TransactionID string

+ type TransactionMutableItemMetaATR struct

+ BucketName string

+ CollectionName string

+ DocID string

+ ScopeName string

+ type TransactionOperationFailedError struct

+ func (tfe TransactionOperationFailedError) Error() string

+ func (tfe TransactionOperationFailedError) ErrorClass() TransactionErrorClass

+ func (tfe TransactionOperationFailedError) MarshalJSON() ([]byte, error)

+ func (tfe TransactionOperationFailedError) Retry() bool

+ func (tfe TransactionOperationFailedError) Rollback() bool

+ func (tfe TransactionOperationFailedError) ToRaise() TransactionErrorReason

+ func (tfe TransactionOperationFailedError) Unwrap() error

+ type TransactionOptions struct

+ BucketAgentProvider TransactionsBucketAgentProviderFn

+ CustomATRLocation TransactionATRLocation

+ DurabilityLevel TransactionDurabilityLevel

+ ExpirationTime time.Duration

+ KeyValueTimeout time.Duration

+ type TransactionProcessATRStats struct

+ NumEntries int

+ NumEntriesExpired int

+ type TransactionRemoveOptions struct

+ Document *TransactionGetResult

+ type TransactionReplaceOptions struct

+ Document *TransactionGetResult

+ Value json.RawMessage

+ type TransactionResult struct

+ Attempts []TransactionAttempt

+ TransactionID string

+ UnstagingComplete bool

+ type TransactionRollbackCallback func(error)

+ type TransactionStagedMutation struct

+ BucketName string

+ Cas Cas

+ CollectionName string

+ Key []byte

+ OpType TransactionStagedMutationType

+ ScopeName string

+ Staged json.RawMessage

+ type TransactionStagedMutationType int

+ type TransactionStoreCallback func(*TransactionGetResult, error)

+ type TransactionUpdateStateOptions struct

+ HasExpired bool

+ ShouldNotCommit bool

+ ShouldNotRetry bool

+ ShouldNotRollback bool

+ State TransactionAttemptState

+ type TransactionsBucketAgentProviderFn func(bucketName string) (*Agent, string, error)

+ type TransactionsCleaner interface

+ AddRequest func(req *TransactionsCleanupRequest) bool

+ CleanupAttempt func(atrAgent *Agent, atrOboUser string, req *TransactionsCleanupRequest, ...)

+ Close func()

+ ForceCleanupQueue func(cb func([]TransactionsCleanupAttempt))

+ PopRequest func() *TransactionsCleanupRequest

+ QueueLength func() int32

+ func NewTransactionsCleaner(config *TransactionsConfig) TransactionsCleaner

+ type TransactionsCleanupAttempt struct

+ AtrBucketName string

+ AtrCollectionName string

+ AtrID []byte

+ AtrScopeName string

+ AttemptID string

+ IsReqular bool

+ Request *TransactionsCleanupRequest

+ Success bool

+ func (ca TransactionsCleanupAttempt) String() string

+ type TransactionsCleanupRequest struct

+ AtrBucketName string

+ AtrCollectionName string

+ AtrID []byte

+ AtrScopeName string

+ AttemptID string

+ DurabilityLevel TransactionDurabilityLevel

+ ForwardCompat map[string][]TransactionForwardCompatibilityEntry

+ Inserts []TransactionsDocRecord

+ Removes []TransactionsDocRecord

+ Replaces []TransactionsDocRecord

+ State TransactionAttemptState

+ func (cr *TransactionsCleanupRequest) String() string

+ type TransactionsConfig struct

+ BucketAgentProvider TransactionsBucketAgentProviderFn

+ CleanupClientAttempts bool

+ CleanupLostAttempts bool

+ CleanupQueueSize uint32

+ CleanupWatchATRs bool

+ CleanupWindow time.Duration

+ CustomATRLocation TransactionATRLocation

+ DurabilityLevel TransactionDurabilityLevel

+ ExpirationTime time.Duration

+ Internal struct{ ... }

+ KeyValueTimeout time.Duration

+ LostCleanupATRLocationProvider TransactionsLostCleanupATRLocationProviderFn

+ type TransactionsDocRecord struct

+ BucketName string

+ CollectionName string

+ ID []byte

+ ScopeName string

+ type TransactionsLostCleanupATRLocationProviderFn func() ([]TransactionLostATRLocation, error)

+ type TransactionsManager struct

+ func InitTransactions(config *TransactionsConfig) (*TransactionsManager, error)

+ func (t *TransactionsManager) BeginTransaction(perConfig *TransactionOptions) (*Transaction, error)

+ func (t *TransactionsManager) Close() error

+ func (t *TransactionsManager) Config() TransactionsConfig

+ func (t *TransactionsManager) Internal() *TransactionsManagerInternal

+ func (t *TransactionsManager) ResumeTransactionAttempt(txnBytes []byte, options *ResumeTransactionOptions) (*Transaction, error)

+ type TransactionsManagerInternal struct

+ func (t *TransactionsManagerInternal) CleanupQueueLength() int32

+ func (t *TransactionsManagerInternal) CreateGetResult(opts TransactionCreateGetResultOptions) *TransactionGetResult

+ func (t *TransactionsManagerInternal) ForceCleanupQueue(cb func([]TransactionsCleanupAttempt))

v10.0.10

Jun 22, 2023

Changes in this version

+ type DCPRollbackError struct

+ InnerError error

+ SeqNo SeqNo

+ func (err DCPRollbackError) Error() string

+ func (err DCPRollbackError) MarshalJSON() ([]byte, error)

+ func (err DCPRollbackError) Unwrap() error

v10.0.9

Mar 15, 2022

v10.0.8

Feb 15, 2022

Changes in this version

type KVConfig

+ ConnectionBufferSize uint

v10.0.7

Jan 24, 2022

Changes in this version

+ var ErrDCPStreamIDInvalid = errors.New("stream ID invalid")

+ var ErrMemdDCPStreamIDInvalid = makeKvStatusError(memd.StatusDCPStreamIDInvalid)

v10.0.6

Dec 14, 2021

Changes in this version

+ var ErrQuotaLimitedFailure = errors.New("quota limited failure")

+ var ErrRateLimitedFailure = errors.New("rate limited failure")

type AnalyticsError

+ ErrorText string

+ HTTPResponseCode int

type N1QLError

+ ErrorText string

+ HTTPResponseCode int

type N1QLQueryOptions

+ Endpoint string

type N1QLRowReader

+ func (q *N1QLRowReader) Endpoint() string

type ViewError

+ ErrorText string

+ HTTPResponseCode int

v10.0.5

Nov 16, 2021

Changes in this version

+ var ErrMemdRateLimitedMaxCommands = makeKvStatusError(memd.StatusRateLimitedMaxCommands)

+ var ErrMemdRateLimitedMaxConnections = makeKvStatusError(memd.StatusRateLimitedMaxConnections)

+ var ErrMemdRateLimitedNetworkEgress = makeKvStatusError(memd.StatusRateLimitedNetworkEgress)

+ var ErrMemdRateLimitedNetworkIngress = makeKvStatusError(memd.StatusRateLimitedNetworkIngress)

+ var ErrMemdRateLimitedScopeSizeLimitExceeded = makeKvStatusError(memd.StatusRateLimitedScopeSizeLimitExceeded)

+ var ErrQuotaLimitingFailure = errors.New("quota limiting failure")

+ var ErrRateLimitingFailure = errors.New("rate limiting failure")

type Agent

+ func (agent *Agent) ReconfigureSecurity(opts ReconfigureSecurityOptions) error

type DCPAgent

+ func (agent *DCPAgent) ReconfigureSecurity(opts ReconfigureSecurityOptions) error

type KVConfig

+ ServerWaitBackoff time.Duration

type N1QLError

+ ResponseBody string

+ type ReconfigureSecurityOptions struct

+ Auth AuthProvider

+ AuthMechanisms []AuthMechanism

+ TLSRootCAProvider func() *x509.CertPool

+ UseTLS bool

type SecurityConfig

+ NoTLSSeedNode bool

v10.0.4

Oct 19, 2021

Changes in this version

+ var ErrMemdClientClosed = errors.New("memdclient closed")

+ var ErrRequestAlreadyDispatched = errors.New("request already dispatched")

v10.0.3

Sep 21, 2021

Changes in this version

type SecurityConfig

+ InitialBootstrapNonTLS bool

v10.0.2

Aug 17, 2021

Changes in this version

+ var ErrEventingFunctionCompilationFailure = errors.New("eventing function compilation failure")

+ var ErrEventingFunctionIdenticalKeyspace = errors.New("eventing function identical keyspace")

+ var ErrEventingFunctionNotBootstrapped = errors.New("eventing function not bootstrapped")

+ var ErrEventingFunctionNotDeployed = errors.New("eventing function not deployed")

+ var ErrEventingFunctionNotFound = errors.New("eventing function not found")

+ var ErrEventingFunctionNotUndeployed = errors.New("eventing function not undeployed")

+ var ErrForcedReconnect = errors.New("forced reconnect")

type Agent

+ func (agent *Agent) ForceReconnect()

type AnalyticsQueryOptions

+ User string

type DCPAgent

+ func (agent *DCPAgent) ForceReconnect()

type HTTPRequest

+ User string

type N1QLQueryOptions

+ User string

type SearchQueryOptions

+ User string

type ViewQueryOptions

+ User string

v10.0.1

Jul 15, 2021

Changes in this version

+ const BackupService

+ const BinaryType

+ const CapiService

+ const CbasService

+ const ClusterCapabilityEnhancedPreparedStatements

+ const ClusterStateDegraded

+ const ClusterStateOffline

+ const ClusterStateOnline

+ const DcpAgentPriorityHigh

+ const DcpAgentPriorityLow

+ const DcpAgentPriorityMed

+ const EventingService

+ const FtsService

+ const GSIService

+ const JSONType

+ const MemdService

+ const MgmtService

+ const N1qlService

+ const NoCompression

+ const PlainAuthMechanism

+ const ScramSha1AuthMechanism

+ const ScramSha256AuthMechanism

+ const ScramSha512AuthMechanism

+ const StringType

+ const UnknownCompression

+ const UnknownType

+ var AnalyticsTemporaryFailureRetryReason = retryReason

+ var BucketNotReadyReason = retryReason

+ var CircuitBreakerOpenRetryReason = retryReason

+ var ConnectionErrorRetryReason = 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 ErrDCPBackfillFailed = makeStreamEndStatusError(memd.StreamEndBackfillFailed)

+ var ErrDCPStreamClosed = makeStreamEndStatusError(memd.StreamEndClosed)

+ var ErrDCPStreamDisconnected = makeStreamEndStatusError(memd.StreamEndDisconnected)

+ var ErrDCPStreamFilterEmpty = makeStreamEndStatusError(memd.StreamEndFilterEmpty)

+ var ErrDCPStreamStateChanged = makeStreamEndStatusError(memd.StreamEndStateChanged)

+ var ErrDCPStreamTooSlow = makeStreamEndStatusError(memd.StreamEndTooSlow)

+ var ErrDMLFailure = errors.New("data service returned an error during execution of DML statement")

+ 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 ErrGCCCPInUse = errors.New("connected via gcccp, kv operations are not supported, open a bucket first")

+ 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(memd.StatusAccessError)

+ var ErrMemdAuthContinue = makeKvStatusError(memd.StatusAuthContinue)

+ var ErrMemdAuthError = makeKvStatusError(memd.StatusAuthError)

+ var ErrMemdAuthStale = makeKvStatusError(memd.StatusAuthStale)

+ var ErrMemdBadDelta = makeKvStatusError(memd.StatusBadDelta)

+ var ErrMemdBusy = makeKvStatusError(memd.StatusBusy)

+ var ErrMemdCollectionNotFound = makeKvStatusError(memd.StatusCollectionUnknown)

+ var ErrMemdDurabilityImpossible = makeKvStatusError(memd.StatusDurabilityImpossible)

+ var ErrMemdDurabilityInvalidLevel = makeKvStatusError(memd.StatusDurabilityInvalidLevel)

+ var ErrMemdInternalError = makeKvStatusError(memd.StatusInternalError)

+ var ErrMemdInvalidArgs = makeKvStatusError(memd.StatusInvalidArgs)

+ var ErrMemdKeyExists = makeKvStatusError(memd.StatusKeyExists)

+ var ErrMemdKeyNotFound = makeKvStatusError(memd.StatusKeyNotFound)

+ var ErrMemdLocked = makeKvStatusError(memd.StatusLocked)

+ var ErrMemdNoBucket = makeKvStatusError(memd.StatusNoBucket)

+ var ErrMemdNotInitialized = makeKvStatusError(memd.StatusNotInitialized)

+ var ErrMemdNotMyVBucket = makeKvStatusError(memd.StatusNotMyVBucket)

+ var ErrMemdNotStored = makeKvStatusError(memd.StatusNotStored)

+ var ErrMemdNotSupported = makeKvStatusError(memd.StatusNotSupported)

+ var ErrMemdOutOfMemory = makeKvStatusError(memd.StatusOutOfMemory)

+ var ErrMemdRangeError = makeKvStatusError(memd.StatusRangeError)

+ var ErrMemdRollback = makeKvStatusError(memd.StatusRollback)

+ var ErrMemdScopeNotFound = makeKvStatusError(memd.StatusScopeUnknown)

+ var ErrMemdSubDocBadCombo = makeKvStatusError(memd.StatusSubDocBadCombo)

+ var ErrMemdSubDocBadDelta = makeKvStatusError(memd.StatusSubDocBadDelta)

+ var ErrMemdSubDocBadMulti = makeKvStatusError(memd.StatusSubDocBadMulti)

+ var ErrMemdSubDocBadRange = makeKvStatusError(memd.StatusSubDocBadRange)

+ var ErrMemdSubDocCantInsert = makeKvStatusError(memd.StatusSubDocCantInsert)

+ var ErrMemdSubDocDocTooDeep = makeKvStatusError(memd.StatusSubDocDocTooDeep)

+ var ErrMemdSubDocMultiPathFailureDeleted = makeKvStatusError(memd.StatusSubDocMultiPathFailureDeleted)

+ var ErrMemdSubDocNotJSON = makeKvStatusError(memd.StatusSubDocNotJSON)

+ var ErrMemdSubDocPathExists = makeKvStatusError(memd.StatusSubDocPathExists)

+ var ErrMemdSubDocPathInvalid = makeKvStatusError(memd.StatusSubDocPathInvalid)

+ var ErrMemdSubDocPathMismatch = makeKvStatusError(memd.StatusSubDocPathMismatch)

+ var ErrMemdSubDocPathNotFound = makeKvStatusError(memd.StatusSubDocPathNotFound)

+ var ErrMemdSubDocPathTooBig = makeKvStatusError(memd.StatusSubDocPathTooBig)

+ var ErrMemdSubDocSuccessDeleted = makeKvStatusError(memd.StatusSubDocSuccessDeleted)

+ var ErrMemdSubDocValueTooDeep = makeKvStatusError(memd.StatusSubDocValueTooDeep)

+ var ErrMemdSubDocXattrCannotModifyVAttr = makeKvStatusError(memd.StatusSubDocXattrCannotModifyVAttr)

+ var ErrMemdSubDocXattrInvalidFlagCombo = makeKvStatusError(memd.StatusSubDocXattrInvalidFlagCombo)

+ var ErrMemdSubDocXattrInvalidKeyCombo = makeKvStatusError(memd.StatusSubDocXattrInvalidKeyCombo)

+ var ErrMemdSubDocXattrUnknownMacro = makeKvStatusError(memd.StatusSubDocXattrUnknownMacro)

+ var ErrMemdSubDocXattrUnknownVAttr = makeKvStatusError(memd.StatusSubDocXattrUnknownVAttr)

+ var ErrMemdSyncWriteAmbiguous = makeKvStatusError(memd.StatusSyncWriteAmbiguous)

+ var ErrMemdSyncWriteInProgess = makeKvStatusError(memd.StatusSyncWriteInProgress)

+ var ErrMemdSyncWriteReCommitInProgress = makeKvStatusError(memd.StatusSyncWriteReCommitInProgress)

+ var ErrMemdTmpFail = makeKvStatusError(memd.StatusTmpFail)

+ var ErrMemdTooBig = makeKvStatusError(memd.StatusTooBig)

+ var ErrMemdUnknownCommand = makeKvStatusError(memd.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 ErrNotMyVBucket = errors.New("not my vbucket")

+ 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 ErrStreamIDNotEnabled = errors.New("stream IDs have not been enabled on this stream")

+ 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 MemdWriteFailure = retryReason

+ var NoPipelineSnapshotRetryReason = retryReason

+ var NodeNotAvailableRetryReason = retryReason

+ var NotReadyRetryReason = 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

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ Value []byte

+ type AdjoinCallback func(*AdjoinResult, error)

+ type AdjoinOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Key []byte

+ PreserveExpiry bool

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ Value []byte

+ type AdjoinResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type Agent struct

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

+ func (agent *Agent) Add(opts AddOptions, cb StoreCallback) (PendingOp, error)

+ func (agent *Agent) AnalyticsQuery(opts AnalyticsQueryOptions, cb AnalyticsQueryCallback) (PendingOp, error)

+ func (agent *Agent) Append(opts AdjoinOptions, cb AdjoinCallback) (PendingOp, error)

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

+ func (agent *Agent) BucketName() string

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

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

+ func (agent *Agent) ClientID() string

+ func (agent *Agent) Close() error

+ func (agent *Agent) ConfigSnapshot() (*ConfigSnapshot, error)

+ func (agent *Agent) Decrement(opts CounterOptions, cb CounterCallback) (PendingOp, error)

+ func (agent *Agent) Delete(opts DeleteOptions, cb DeleteCallback) (PendingOp, error)

+ func (agent *Agent) DeleteMeta(opts DeleteMetaOptions, cb DeleteMetaCallback) (PendingOp, error)

+ func (agent *Agent) Diagnostics(opts DiagnosticsOptions) (*DiagnosticInfo, error)

+ func (agent *Agent) DoHTTPRequest(req *HTTPRequest, cb DoHTTPRequestCallback) (PendingOp, error)

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

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

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

+ func (agent *Agent) Get(opts GetOptions, cb GetCallback) (PendingOp, error)

+ func (agent *Agent) GetAllCollectionManifests(opts GetAllCollectionManifestsOptions, cb GetAllCollectionManifestsCallback) (PendingOp, error)

+ func (agent *Agent) GetAndLock(opts GetAndLockOptions, cb GetAndLockCallback) (PendingOp, error)

+ func (agent *Agent) GetAndTouch(opts GetAndTouchOptions, cb GetAndTouchCallback) (PendingOp, error)

+ func (agent *Agent) GetCollectionID(scopeName string, collectionName string, opts GetCollectionIDOptions, ...) (PendingOp, error)

+ func (agent *Agent) GetCollectionManifest(opts GetCollectionManifestOptions, cb GetCollectionManifestCallback) (PendingOp, error)

+ func (agent *Agent) GetMeta(opts GetMetaOptions, cb GetMetaCallback) (PendingOp, error)

+ func (agent *Agent) GetOneReplica(opts GetOneReplicaOptions, cb GetReplicaCallback) (PendingOp, error)

+ func (agent *Agent) GetRandom(opts GetRandomOptions, cb GetRandomCallback) (PendingOp, error)

+ func (agent *Agent) HTTPClient() *http.Client

+ func (agent *Agent) HasCollectionsSupport() bool

+ func (agent *Agent) HasSeenConfig() (bool, error)

+ func (agent *Agent) Increment(opts CounterOptions, cb CounterCallback) (PendingOp, error)

+ func (agent *Agent) Internal() *AgentInternal

+ func (agent *Agent) IsSecure() bool

+ func (agent *Agent) LookupIn(opts LookupInOptions, cb LookupInCallback) (PendingOp, error)

+ func (agent *Agent) MaybeRetryRequest(req RetryRequest, reason RetryReason) (bool, time.Time)

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

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

+ func (agent *Agent) MutateIn(opts MutateInOptions, cb MutateInCallback) (PendingOp, error)

+ func (agent *Agent) N1QLQuery(opts N1QLQueryOptions, cb N1QLQueryCallback) (PendingOp, error)

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

+ func (agent *Agent) Observe(opts ObserveOptions, cb ObserveCallback) (PendingOp, error)

+ func (agent *Agent) ObserveVb(opts ObserveVbOptions, cb ObserveVbCallback) (PendingOp, error)

+ func (agent *Agent) Ping(opts PingOptions, cb PingCallback) (PendingOp, error)

+ func (agent *Agent) PreparedN1QLQuery(opts N1QLQueryOptions, cb N1QLQueryCallback) (PendingOp, error)

+ func (agent *Agent) Prepend(opts AdjoinOptions, cb AdjoinCallback) (PendingOp, error)

+ func (agent *Agent) Replace(opts ReplaceOptions, cb StoreCallback) (PendingOp, error)

+ func (agent *Agent) SearchQuery(opts SearchQueryOptions, cb SearchQueryCallback) (PendingOp, error)

+ func (agent *Agent) Set(opts SetOptions, cb StoreCallback) (PendingOp, error)

+ func (agent *Agent) SetMeta(opts SetMetaOptions, cb SetMetaCallback) (PendingOp, error)

+ func (agent *Agent) Stats(opts StatsOptions, cb StatsCallback) (PendingOp, error)

+ func (agent *Agent) Touch(opts TouchOptions, cb TouchCallback) (PendingOp, error)

+ func (agent *Agent) Unlock(opts UnlockOptions, cb UnlockCallback) (PendingOp, error)

+ func (agent *Agent) UsingGCCCP() bool

+ func (agent *Agent) ViewQuery(opts ViewQueryOptions, cb ViewQueryCallback) (PendingOp, error)

+ func (agent *Agent) WaitUntilReady(deadline time.Time, opts WaitUntilReadyOptions, cb WaitUntilReadyCallback) (PendingOp, error)

+ type AgentConfig struct

+ BucketName string

+ CircuitBreakerConfig CircuitBreakerConfig

+ CompressionConfig CompressionConfig

+ ConfigPollerConfig ConfigPollerConfig

+ DefaultRetryStrategy RetryStrategy

+ HTTPConfig HTTPConfig

+ IoConfig IoConfig

+ KVConfig KVConfig

+ MeterConfig MeterConfig

+ OrphanReporterConfig OrphanReporterConfig

+ SecurityConfig SecurityConfig

+ SeedConfig SeedConfig

+ TracerConfig TracerConfig

+ UserAgent string

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

+ type AgentGroup struct

+ func CreateAgentGroup(config *AgentGroupConfig) (*AgentGroup, error)

+ func (ag *AgentGroup) AnalyticsQuery(opts AnalyticsQueryOptions, cb AnalyticsQueryCallback) (PendingOp, error)

+ func (ag *AgentGroup) Close() error

+ func (ag *AgentGroup) Diagnostics(opts DiagnosticsOptions) (*DiagnosticInfo, error)

+ func (ag *AgentGroup) DoHTTPRequest(req *HTTPRequest, cb DoHTTPRequestCallback) (PendingOp, error)

+ func (ag *AgentGroup) GetAgent(bucketName string) *Agent

+ func (ag *AgentGroup) N1QLQuery(opts N1QLQueryOptions, cb N1QLQueryCallback) (PendingOp, error)

+ func (ag *AgentGroup) OpenBucket(bucketName string) error

+ func (ag *AgentGroup) Ping(opts PingOptions, cb PingCallback) (PendingOp, error)

+ func (ag *AgentGroup) PreparedN1QLQuery(opts N1QLQueryOptions, cb N1QLQueryCallback) (PendingOp, error)

+ func (ag *AgentGroup) SearchQuery(opts SearchQueryOptions, cb SearchQueryCallback) (PendingOp, error)

+ func (ag *AgentGroup) WaitUntilReady(deadline time.Time, opts WaitUntilReadyOptions, cb WaitUntilReadyCallback) (PendingOp, error)

+ type AgentGroupConfig struct

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

+ type AgentInternal struct

+ func (ai *AgentInternal) BucketCapabilityStatus(cap BucketCapability) BucketCapabilityStatus

+ 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) MarshalJSON() ([]byte, error)

+ func (e AnalyticsError) Unwrap() error

+ type AnalyticsErrorDesc struct

+ Code uint32

+ Message string

+ type AnalyticsQueryCallback func(*AnalyticsRowReader, error)

+ type AnalyticsQueryOptions struct

+ Deadline time.Time

+ Payload []byte

+ Priority int

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ 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 memd.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 BackoffCalculator func(retryAttempts uint32) time.Duration

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

+ type BestEffortRetryStrategy struct

+ func NewBestEffortRetryStrategy(calculator BackoffCalculator) *BestEffortRetryStrategy

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

+ type BucketCapability uint32

+ const BucketCapabilityCreateAsDeleted

+ const BucketCapabilityDurableWrites

+ const BucketCapabilityReplaceBodyWithXattr

+ type BucketCapabilityStatus uint32

+ const BucketCapabilityStatusSupported

+ const BucketCapabilityStatusUnknown

+ const BucketCapabilityStatusUnsupported

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

+ StreamOptions *CloseStreamStreamOptions

+ type CloseStreamStreamOptions struct

+ StreamID uint16

+ type ClusterCapability uint32

+ type ClusterState uint32

+ type CompressionConfig struct

+ DisableDecompression bool

+ Enabled bool

+ MinRatio float64

+ MinSize int

+ type CompressionType uint32

+ type ConfigPollerConfig struct

+ CccpMaxWait time.Duration

+ CccpPollPeriod time.Duration

+ HTTPMaxWait time.Duration

+ HTTPRedialPeriod time.Duration

+ HTTPRetryDelay time.Duration

+ type ConfigSnapshot struct

+ func (pi ConfigSnapshot) BucketUUID() string

+ func (pi ConfigSnapshot) KeyToServer(key []byte, replicaIdx uint32) (int, error)

+ func (pi ConfigSnapshot) KeyToVbucket(key []byte) (uint16, error)

+ func (pi ConfigSnapshot) NumReplicas() (int, error)

+ func (pi ConfigSnapshot) NumServers() (int, error)

+ func (pi ConfigSnapshot) NumVbuckets() (int, error)

+ func (pi ConfigSnapshot) RevID() int64

+ func (pi ConfigSnapshot) VbucketToServer(vbID uint16, replicaIdx uint32) (int, error)

+ func (pi ConfigSnapshot) VbucketsOnServer(index int) ([]uint16, error)

+ type Counter interface

+ IncrementBy func(num uint64)

+ type CounterCallback func(*CounterResult, error)

+ type CounterOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Delta uint64

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Initial uint64

+ Key []byte

+ PreserveExpiry bool

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type CounterResult struct

+ Cas Cas

+ MutationToken MutationToken

+ Value uint64

+ type DCPAgent struct

+ func CreateDcpAgent(config *DCPAgentConfig, dcpStreamName string, openFlags memd.DcpOpenFlag) (*DCPAgent, error)

+ func (agent *DCPAgent) Close() error

+ func (agent *DCPAgent) CloseStream(vbID uint16, opts CloseStreamOptions, cb CloseStreamCallback) (PendingOp, error)

+ func (agent *DCPAgent) ConfigSnapshot() (*ConfigSnapshot, error)

+ func (agent *DCPAgent) GetFailoverLog(vbID uint16, cb GetFailoverLogCallback) (PendingOp, error)

+ func (agent *DCPAgent) GetVbucketSeqnos(serverIdx int, state memd.VbucketState, opts GetVbucketSeqnoOptions, ...) (PendingOp, error)

+ func (agent *DCPAgent) HasCollectionsSupport() bool

+ func (agent *DCPAgent) IsSecure() bool

+ func (agent *DCPAgent) OpenStream(vbID uint16, flags memd.DcpStreamAddFlag, vbUUID VbUUID, ...) (PendingOp, error)

+ func (agent *DCPAgent) WaitUntilReady(deadline time.Time, opts WaitUntilReadyOptions, cb WaitUntilReadyCallback) (PendingOp, error)

+ type DCPAgentConfig struct

+ BucketName string

+ CompressionConfig CompressionConfig

+ ConfigPollerConfig ConfigPollerConfig

+ DCPConfig DCPConfig

+ HTTPConfig HTTPConfig

+ IoConfig IoConfig

+ KVConfig KVConfig

+ SecurityConfig SecurityConfig

+ SeedConfig SeedConfig

+ UserAgent string

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

+ type DCPBackfillOrder uint8

+ const DCPBackfillOrderRoundRobin

+ const DCPBackfillOrderSequential

+ type DCPConfig struct

+ AgentPriority DcpAgentPriority

+ BackfillOrder DCPBackfillOrder

+ BufferSize int

+ DisableBufferAcknowledgement bool

+ UseExpiryOpcode bool

+ UseOSOBackfill bool

+ UseStreamID bool

+ type DataType uint32

+ type DcpAgentPriority uint8

+ type DcpCollectionCreation struct

+ CollectionID uint32

+ Key []byte

+ ManifestUID uint64

+ ScopeID uint32

+ SeqNo uint64

+ StreamID uint16

+ Ttl uint32

+ VbID uint16

+ Version uint8

+ type DcpCollectionDeletion struct

+ CollectionID uint32

+ ManifestUID uint64

+ ScopeID uint32

+ SeqNo uint64

+ StreamID uint16

+ VbID uint16

+ Version uint8

+ type DcpCollectionFlush struct

+ CollectionID uint32

+ ManifestUID uint64

+ SeqNo uint64

+ StreamID uint16

+ VbID uint16

+ Version uint8

+ type DcpCollectionModification struct

+ CollectionID uint32

+ ManifestUID uint64

+ SeqNo uint64

+ StreamID uint16

+ Ttl uint32

+ VbID uint16

+ Version uint8

+ type DcpDeletion struct

+ Cas uint64

+ CollectionID uint32

+ Datatype uint8

+ DeleteTime uint32

+ Key []byte

+ RevNo uint64

+ SeqNo uint64

+ StreamID uint16

+ Value []byte

+ VbID uint16

+ type DcpExpiration struct

+ Cas uint64

+ CollectionID uint32

+ DeleteTime uint32

+ Key []byte

+ RevNo uint64

+ SeqNo uint64

+ StreamID uint16

+ VbID uint16

+ type DcpMutation struct

+ Cas uint64

+ CollectionID uint32

+ Datatype uint8

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ LockTime uint32

+ RevNo uint64

+ SeqNo uint64

+ StreamID uint16

+ Value []byte

+ VbID uint16

+ type DcpOSOSnapshot struct

+ SnapshotType uint32

+ StreamID uint16

+ VbID uint16

+ type DcpScopeCreation struct

+ Key []byte

+ ManifestUID uint64

+ ScopeID uint32

+ SeqNo uint64

+ StreamID uint16

+ VbID uint16

+ Version uint8

+ type DcpScopeDeletion struct

+ ManifestUID uint64

+ ScopeID uint32

+ SeqNo uint64

+ StreamID uint16

+ VbID uint16

+ Version uint8

+ type DcpSeqNoAdvanced struct

+ SeqNo uint64

+ StreamID uint16

+ VbID uint16

+ type DcpSnapshotMarker struct

+ EndSeqNo uint64

+ HighCompletedSeqNo uint64

+ MaxVisibleSeqNo uint64

+ SnapshotTimeStamp uint64

+ SnapshotType SnapshotState

+ StartSeqNo uint64

+ StreamID uint16

+ VbID uint16

+ type DcpStreamEnd struct

+ StreamID uint16

+ VbID uint16

+ type DeleteCallback func(*DeleteResult, error)

+ type DeleteMetaCallback func(*DeleteMetaResult, error)

+ type DeleteMetaOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ Expiry uint32

+ Extra []byte

+ Flags uint32

+ Key []byte

+ Options uint32

+ RetryStrategy RetryStrategy

+ RevNo uint64

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ Value []byte

+ type DeleteMetaResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type DeleteOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type DeleteResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type DiagnosticInfo struct

+ ConfigRev int64

+ MemdConns []MemdConnInfo

+ State ClusterState

+ type DiagnosticsOptions struct

+ type DoHTTPRequestCallback func(*HTTPResponse, error)

+ type EndpointPingResult struct

+ Endpoint string

+ Error error

+ ID string

+ Latency time.Duration

+ Scope string

+ State PingState

+ type EndpointState uint32

+ const EndpointStateConnected

+ const EndpointStateConnecting

+ const EndpointStateDisconnected

+ const EndpointStateDisconnecting

+ type ExecHelloResponse struct

+ Err error

+ SrvFeatures []memd.HelloFeature

+ type FailoverEntry struct

+ SeqNo SeqNo

+ VbUUID VbUUID

+ type GetAllCollectionManifestsCallback func(*GetAllCollectionManifestsResult, error)

+ type GetAllCollectionManifestsOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetAllCollectionManifestsResult struct

+ Manifests map[string]SingleServerManifestResult

+ type GetAndLockCallback func(*GetAndLockResult, error)

+ type GetAndLockOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ LockTime uint32

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type GetAndLockResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetAndTouchCallback func(*GetAndTouchResult, error)

+ type GetAndTouchOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Expiry uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type GetAndTouchResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetAnyReplicaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type GetCallback func(*GetResult, error)

+ type GetCollectionIDCallback func(*GetCollectionIDResult, error)

+ type GetCollectionIDOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetCollectionIDResult struct

+ CollectionID uint32

+ ManifestID uint64

+ type GetCollectionManifestCallback func(*GetCollectionManifestResult, error)

+ type GetCollectionManifestOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetCollectionManifestResult struct

+ Manifest []byte

+ type GetFailoverLogCallback func([]FailoverEntry, error)

+ type GetMetaCallback func(*GetMetaResult, error)

+ type GetMetaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type GetMetaResult struct

+ Cas Cas

+ Datatype uint8

+ Deleted uint32

+ Expiry uint32

+ Flags uint32

+ SeqNo SeqNo

+ Value []byte

+ type GetOneReplicaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type GetOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type GetRandomCallback func(*GetRandomResult, error)

+ type GetRandomOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type GetRandomResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Key []byte

+ Value []byte

+ type GetReplicaCallback 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 GetVbucketSeqnoFilterOptions struct

+ CollectionID uint32

+ type GetVbucketSeqnoOptions struct

+ FilterOptions *GetVbucketSeqnoFilterOptions

+ type HTTPConfig struct

+ IdleConnectionTimeout time.Duration

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ type HTTPError struct

+ Endpoint string

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ UniqueID string

+ func (e HTTPError) Error() string

+ func (e HTTPError) MarshalJSON() ([]byte, error)

+ func (e HTTPError) Unwrap() error

+ type HTTPRequest struct

+ Body []byte

+ ContentType string

+ Deadline time.Time

+ Endpoint string

+ Headers map[string]string

+ IsIdempotent bool

+ Method string

+ Password string

+ Path string

+ RetryStrategy RetryStrategy

+ Service ServiceType

+ TraceContext RequestSpanContext

+ UniqueID string

+ Username string

+ type HTTPResponse struct

+ Body io.ReadCloser

+ ContentLength int64

+ Endpoint string

+ StatusCode int

+ type IoConfig struct

+ DisableJSONHello bool

+ DisableSyncReplicationHello bool

+ DisableXErrorHello bool

+ EnablePITRHello bool

+ NetworkType string

+ UseCollections bool

+ UseDurations bool

+ UseMutationTokens bool

+ UseOutOfOrderResponses bool

+ type KVConfig struct

+ ConnectTimeout time.Duration

+ MaxQueueSize int

+ PoolSize int

+ type KeyValueError struct

+ BucketName string

+ CollectionID uint32

+ CollectionName string

+ Context string

+ DocumentKey string

+ ErrorDescription string

+ ErrorName string

+ InnerError error

+ LastConnectionID string

+ LastDispatchedFrom string

+ LastDispatchedTo string

+ Opaque uint32

+ Ref string

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ ScopeName string

+ StatusCode memd.StatusCode

+ func (e KeyValueError) Error() string

+ func (e KeyValueError) MarshalJSON() ([]byte, error)

+ 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 LookupInCallback func(*LookupInResult, error)

+ type LookupInOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Flags memd.SubdocDocFlag

+ Key []byte

+ Ops []SubDocOp

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type LookupInResult struct

+ Cas Cas

+ Internal struct{ ... }

+ Ops []SubDocResult

+ type Manifest struct

+ Scopes []ManifestScope

+ UID uint64

+ func (item *Manifest) UnmarshalJSON(data []byte) error

+ type ManifestCollection struct

+ MaxTTL uint32

+ 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

+ State EndpointState

+ type Meter interface

+ Counter func(name string, tags map[string]string) (Counter, error)

+ ValueRecorder func(name string, tags map[string]string) (ValueRecorder, error)

+ type MeterConfig struct

+ Meter Meter

+ type MutateInCallback func(*MutateInResult, error)

+ type MutateInOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags memd.SubdocDocFlag

+ Key []byte

+ Ops []SubDocOp

+ PreserveExpiry bool

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ 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) MarshalJSON() ([]byte, error)

+ func (e N1QLError) Unwrap() error

+ type N1QLErrorDesc struct

+ Code uint32

+ Message string

+ type N1QLQueryCallback func(*N1QLRowReader, error)

+ type N1QLQueryOptions struct

+ Deadline time.Time

+ Payload []byte

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type N1QLRowReader struct

+ func (q *N1QLRowReader) Close() error

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

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

+ func (q N1QLRowReader) Err() error

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

+ type NoRetryRetryAction struct

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

+ type ObserveCallback func(*ObserveResult, error)

+ type ObserveOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type ObserveResult struct

+ Cas Cas

+ KeyState memd.KeyState

+ type ObserveVbCallback func(*ObserveVbResult, error)

+ type ObserveVbOptions struct

+ Deadline time.Time

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ User []byte

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

+ CollectionIDs []uint32

+ ScopeID uint32

+ type OpenStreamManifestOptions struct

+ ManifestUID uint64

+ type OpenStreamOptions struct

+ FilterOptions *OpenStreamFilterOptions

+ ManifestOptions *OpenStreamManifestOptions

+ StreamOptions *OpenStreamStreamOptions

+ type OpenStreamStreamOptions struct

+ StreamID uint16

+ type OrphanReporterConfig struct

+ Enabled bool

+ ReportInterval time.Duration

+ SampleSize int

+ 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()

+ type PingCallback func(*PingResult, error)

+ type PingOptions struct

+ CapiDeadline time.Time

+ CbasDeadline time.Time

+ FtsDeadline time.Time

+ KVDeadline time.Time

+ MgmtDeadline time.Time

+ N1QLDeadline time.Time

+ ServiceTypes []ServiceType

+ TraceContext RequestSpanContext

+ User []byte

+ type PingResult struct

+ ConfigRev int64

+ Services map[ServiceType][]EndpointPingResult

+ type PingState uint32

+ const PingStateError

+ const PingStateOK

+ const PingStateTimeout

+ type ReplaceOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ PreserveExpiry bool

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ Value []byte

+ type RequestSpan interface

+ AddEvent func(name string, timestamp time.Time)

+ Context func() RequestSpanContext

+ End func()

+ SetAttribute func(key string, value interface{})

+ type RequestSpanContext interface

+ type RequestTracer interface

+ RequestSpan func(parentContext RequestSpanContext, operationName string) 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) MarshalJSON() ([]byte, error)

+ func (e SearchError) Unwrap() error

+ type SearchQueryCallback func(*SearchRowReader, error)

+ type SearchQueryOptions struct

+ Deadline time.Time

+ IndexName string

+ Payload []byte

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

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

+ Auth AuthProvider

+ AuthMechanisms []AuthMechanism

+ TLSRootCAProvider func() *x509.CertPool

+ UseTLS bool

+ type SeedConfig struct

+ HTTPAddrs []string

+ MemdAddrs []string

+ type SeqNo uint64

+ type ServiceType int

+ type SetMetaCallback func(*SetMetaResult, error)

+ type SetMetaOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ Expiry uint32

+ Extra []byte

+ Flags uint32

+ Key []byte

+ Options uint32

+ RetryStrategy RetryStrategy

+ RevNo uint64

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ Value []byte

+ type SetMetaResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type SetOptions struct

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ PreserveExpiry bool

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ Value []byte

+ type SingleServerManifestResult struct

+ Error error

+ Manifest []byte

+ type SingleServerStats struct

+ Error error

+ Stats map[string]string

+ StatsChunks [][]byte

+ StatsKeys [][]byte

+ type SnapshotState uint32

+ func (s SnapshotState) HasInMemory() bool

+ func (s SnapshotState) HasOnDisk() bool

+ type SpanStatus string

+ const SpanStatusError

+ const SpanStatusOK

+ type StatsCallback func(*StatsResult, error)

+ type StatsOptions struct

+ Deadline time.Time

+ Key string

+ RetryStrategy RetryStrategy

+ Target StatsTarget

+ TraceContext RequestSpanContext

+ User []byte

+ type StatsResult struct

+ Servers map[string]SingleServerStats

+ type StatsTarget interface

+ type StoreCallback func(*StoreResult, error)

+ type StoreResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type StreamObserver interface

+ CreateCollection func(creation DcpCollectionCreation)

+ CreateScope func(creation DcpScopeCreation)

+ DeleteCollection func(deletion DcpCollectionDeletion)

+ DeleteScope func(deletion DcpScopeDeletion)

+ Deletion func(deletion DcpDeletion)

+ End func(end DcpStreamEnd, err error)

+ Expiration func(expiration DcpExpiration)

+ FlushCollection func(flush DcpCollectionFlush)

+ ModifyCollection func(modification DcpCollectionModification)

+ Mutation func(mutation DcpMutation)

+ OSOSnapshot func(snapshot DcpOSOSnapshot)

+ SeqNoAdvanced func(seqNoAdvanced DcpSeqNoAdvanced)

+ SnapshotMarker func(snapshotMarker DcpSnapshotMarker)

+ type SubDocOp struct

+ Flags memd.SubdocFlag

+ Op memd.SubDocOpType

+ Path string

+ Value []byte

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

+ InnerError error

+ LastConnectionID string

+ LastDispatchedFrom string

+ LastDispatchedTo string

+ Opaque string

+ OperationID string

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ TimeObserved time.Duration

+ func (err *TimeoutError) MarshalJSON() ([]byte, error)

+ func (err *TimeoutError) UnmarshalJSON(data []byte) error

+ func (err TimeoutError) Error() string

+ func (err TimeoutError) Unwrap() error

+ type TouchCallback func(*TouchResult, error)

+ type TouchOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Expiry uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type TouchResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type TracerConfig struct

+ NoRootTraceSpans bool

+ Tracer RequestTracer

+ type UnlockCallback func(*UnlockResult, error)

+ type UnlockOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ User []byte

+ type UnlockResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type UserPassPair struct

+ Password string

+ Username string

+ type VBucketIDStatsTarget struct

+ VbID uint16

+ type ValueRecorder interface

+ RecordValue func(val uint64)

+ type VbSeqNoEntry struct

+ SeqNo SeqNo

+ VbID uint16

+ type VbUUID uint64

+ 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) MarshalJSON() ([]byte, error)

+ func (e ViewError) Unwrap() error

+ type ViewQueryCallback func(*ViewQueryRowReader, error)

+ type ViewQueryErrorDesc struct

+ Message string

+ SourceNode string

+ type ViewQueryOptions struct

+ Deadline time.Time

+ DesignDocumentName string

+ Options url.Values

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ 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 WaitUntilReadyCallback func(*WaitUntilReadyResult, error)

+ type WaitUntilReadyOptions struct

+ DesiredState ClusterState

+ RetryStrategy RetryStrategy

+ ServiceTypes []ServiceType

+ type WaitUntilReadyResult struct

+ type WithDurationRetryAction struct

+ WithDuration time.Duration

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

Other modules containing this package

github.com/couchbase/gocbcore

github.com/couchbase/gocbcore/v8

github.com/couchbase/gocbcore/v9

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