gocb

package module

Go to main page

Versions in this module

v2

v2.8.1

Apr 17, 2024

Changes in this version

type EventingFunctionLanguageCompatibility

+ var EventingFunctionLanguageCompatibilityVersion720 EventingFunctionLanguageCompatibility = "7.2.0"

type ScanOptions

+ Concurrency uint16

type Scope

+ func (s *Scope) EventingFunctions() *ScopeEventingFunctionManager

+ type ScopeEventingFunctionManager struct

+ func (efm *ScopeEventingFunctionManager) DeployFunction(name string, opts *DeployEventingFunctionOptions) error

+ func (efm *ScopeEventingFunctionManager) DropFunction(name string, opts *DropEventingFunctionOptions) error

+ func (efm *ScopeEventingFunctionManager) FunctionsStatus(opts *EventingFunctionsStatusOptions) (*EventingStatus, error)

+ func (efm *ScopeEventingFunctionManager) GetAllFunctions(opts *GetAllEventingFunctionsOptions) ([]EventingFunction, error)

+ func (efm *ScopeEventingFunctionManager) GetFunction(name string, opts *GetEventingFunctionOptions) (*EventingFunction, error)

+ func (efm *ScopeEventingFunctionManager) PauseFunction(name string, opts *PauseEventingFunctionOptions) error

+ func (efm *ScopeEventingFunctionManager) ResumeFunction(name string, opts *ResumeEventingFunctionOptions) error

+ func (efm *ScopeEventingFunctionManager) UndeployFunction(name string, opts *UndeployEventingFunctionOptions) error

+ func (efm *ScopeEventingFunctionManager) UpsertFunction(function EventingFunction, opts *UpsertEventingFunctionOptions) error

v2.8.0

Mar 13, 2024

Changes in this version

+ type HistoryRetentionCollectionDefault uint8

+ const HistoryRetentionCollectionDefaultDisabled

+ const HistoryRetentionCollectionDefaultEnabled

+ const HistoryRetentionCollectionDefaultUnset

v2.7.2

Feb 20, 2024

Changes in this version

type Bucket

+ func (b *Bucket) CollectionsV2() *CollectionManagerV2

type Cluster

+ func (c *Cluster) Search(indexName string, request SearchRequest, opts *SearchOptions) (*SearchResult, error)

+ type CollectionManagerV2 struct

+ func (cm *CollectionManagerV2) CreateCollection(scopeName string, collectionName string, settings *CreateCollectionSettings, ...) error

+ func (cm *CollectionManagerV2) CreateScope(scopeName string, opts *CreateScopeOptions) error

+ func (cm *CollectionManagerV2) DropCollection(scopeName string, collectionName string, opts *DropCollectionOptions) error

+ func (cm *CollectionManagerV2) DropScope(scopeName string, opts *DropScopeOptions) error

+ func (cm *CollectionManagerV2) GetAllScopes(opts *GetAllScopesOptions) ([]ScopeSpec, error)

+ func (cm *CollectionManagerV2) UpdateCollection(scopeName string, collectionName string, settings UpdateCollectionSettings, ...) error

+ type CreateCollectionSettings struct

+ History *CollectionHistorySettings

+ MaxExpiry time.Duration

type Scope

+ func (s *Scope) Search(indexName string, request SearchRequest, opts *SearchOptions) (*SearchResult, error)

+ func (s *Scope) SearchIndexes() *ScopeSearchIndexManager

+ type ScopeSearchIndexManager struct

+ func (sm *ScopeSearchIndexManager) AllowQuerying(indexName string, opts *AllowQueryingSearchIndexOptions) error

+ func (sm *ScopeSearchIndexManager) AnalyzeDocument(indexName string, doc interface{}, opts *AnalyzeDocumentOptions) ([]interface{}, error)

+ func (sm *ScopeSearchIndexManager) DisallowQuerying(indexName string, opts *DisallowQueryingSearchIndexOptions) error

+ func (sm *ScopeSearchIndexManager) DropIndex(indexName string, opts *DropSearchIndexOptions) error

+ func (sm *ScopeSearchIndexManager) FreezePlan(indexName string, opts *FreezePlanSearchIndexOptions) error

+ func (sm *ScopeSearchIndexManager) GetAllIndexes(opts *GetAllSearchIndexOptions) ([]SearchIndex, error)

+ func (sm *ScopeSearchIndexManager) GetIndex(indexName string, opts *GetSearchIndexOptions) (*SearchIndex, error)

+ func (sm *ScopeSearchIndexManager) GetIndexedDocumentsCount(indexName string, opts *GetIndexedDocumentsCountOptions) (uint64, error)

+ func (sm *ScopeSearchIndexManager) PauseIngest(indexName string, opts *PauseIngestSearchIndexOptions) error

+ func (sm *ScopeSearchIndexManager) ResumeIngest(indexName string, opts *ResumeIngestSearchIndexOptions) error

+ func (sm *ScopeSearchIndexManager) UnfreezePlan(indexName string, opts *UnfreezePlanSearchIndexOptions) error

+ func (sm *ScopeSearchIndexManager) UpsertIndex(indexDefinition SearchIndex, opts *UpsertSearchIndexOptions) error

+ type SearchRequest struct

+ SearchQuery search.Query

+ VectorSearch *vector.Search

+ type UpdateCollectionSettings struct

+ History *CollectionHistorySettings

+ MaxExpiry time.Duration

v2.7.1

Jan 17, 2024

Changes in this version

+ var ErrDocumentNotLocked = gocbcore.ErrDocumentNotLocked

v2.7.0

Nov 21, 2023

Changes in this version

+ var ErrDocumentTooDeep = errors.New("document too deep")

+ var ErrMutationTokenOutdated = gocbcore.ErrRangeScanVbUUIDNotEqual

+ var NotReadyRetryReason = RetryReason(gocbcore.NotReadyRetryReason)

type BucketSettings

+ HistoryRetentionBytes uint64

+ HistoryRetentionCollectionDefault *bool

+ HistoryRetentionDuration time.Duration

type Collection

+ func (c *Collection) LookupInAllReplicas(id string, ops []LookupInSpec, opts *LookupInAllReplicaOptions) (*LookupInAllReplicasResult, error)

+ func (c *Collection) LookupInAnyReplica(id string, ops []LookupInSpec, opts *LookupInAnyReplicaOptions) (*LookupInReplicaResult, error)

+ type CollectionHistorySettings struct

+ Enabled bool

type CollectionManager

+ func (cm *CollectionManager) UpdateCollection(spec CollectionSpec, opts *UpdateCollectionOptions) error

type CollectionSpec

+ History *CollectionHistorySettings

+ type GenericError struct

+ Context map[string]interface{}

+ InnerError error

+ func (e *GenericError) Error() string

+ func (e *GenericError) MarshalJSON() ([]byte, error)

+ func (e *GenericError) Unwrap() error

+ type LookupInAllReplicaOptions struct

+ Context context.Context

+ Internal struct{ ... }

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type LookupInAllReplicasResult struct

+ func (r *LookupInAllReplicasResult) Close() error

+ func (r *LookupInAllReplicasResult) Next() *LookupInReplicaResult

+ type LookupInAnyReplicaOptions struct

+ Context context.Context

+ Internal struct{ ... }

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type LookupInReplicaResult struct

+ func (r *LookupInReplicaResult) IsReplica() bool

type QueryOptions

+ UseReplica QueryUseReplicaLevel

+ type QueryUseReplicaLevel uint

+ const QueryUseReplicaLevelNotSet

+ const QueryUseReplicaLevelOff

+ const QueryUseReplicaLevelOn

type SearchIndex

+ func (si *SearchIndex) MarshalJSON() ([]byte, error)

+ func (si *SearchIndex) UnmarshalJSON(bytes []byte) error

+ type UpdateCollectionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

v2.6.6

Feb 23, 2024

v2.6.5

Oct 18, 2023

Changes in this version

+ var ErrCircuitBreakerOpen = gocbcore.ErrCircuitBreakerOpen

v2.6.4

Sep 26, 2023

v2.6.3

Apr 18, 2023

v2.6.2

Mar 22, 2023

Changes in this version

type CreatePrimaryQueryIndexOptions

+ NumReplicas int

type CreateQueryIndexOptions

+ NumReplicas int

v2.6.1

Feb 22, 2023

Changes in this version

type Collection

+ func (c *Collection) QueryIndexes() *CollectionQueryIndexManager

+ func (c *Collection) Scan(scanType ScanType, opts *ScanOptions) (*ScanResult, error)

+ type CollectionQueryIndexManager struct

+ func (qm *CollectionQueryIndexManager) BuildDeferredIndexes(opts *BuildDeferredQueryIndexOptions) ([]string, error)

+ func (qm *CollectionQueryIndexManager) CreateIndex(indexName string, keys []string, opts *CreateQueryIndexOptions) error

+ func (qm *CollectionQueryIndexManager) CreatePrimaryIndex(opts *CreatePrimaryQueryIndexOptions) error

+ func (qm *CollectionQueryIndexManager) DropIndex(indexName string, opts *DropQueryIndexOptions) error

+ func (qm *CollectionQueryIndexManager) DropPrimaryIndex(opts *DropPrimaryQueryIndexOptions) error

+ func (qm *CollectionQueryIndexManager) GetAllIndexes(opts *GetAllQueryIndexesOptions) ([]QueryIndex, error)

+ func (qm *CollectionQueryIndexManager) WatchIndexes(watchList []string, timeout time.Duration, opts *WatchQueryIndexOptions) error

type InternalConfig

+ ConnectionBufferSize uint

+ type RangeScan struct

+ From *ScanTerm

+ To *ScanTerm

+ func NewRangeScanForPrefix(prefix string) RangeScan

+ type SamplingScan struct

+ Limit uint64

+ Seed uint64

+ type ScanOptions struct

+ BatchByteLimit uint32

+ BatchItemLimit uint32

+ ConsistentWith *MutationState

+ Context context.Context

+ IDsOnly bool

+ Internal struct{ ... }

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Sort ScanSort

+ Timeout time.Duration

+ Transcoder Transcoder

+ type ScanResult struct

+ func (sr *ScanResult) Close() error

+ func (sr *ScanResult) Err() error

+ func (sr *ScanResult) Next() *ScanResultItem

+ type ScanResultItem struct

+ func (sri *ScanResultItem) Cas() Cas

+ func (sri *ScanResultItem) Content(valuePtr interface{}) error

+ func (sri *ScanResultItem) ExpiryTime() time.Time

+ func (sri *ScanResultItem) ID() string

+ func (sri *ScanResultItem) IDOnly() bool

+ type ScanSort uint8

+ const ScanSortAscending

+ const ScanSortNone

+ type ScanTerm struct

+ Exclusive bool

+ Term string

+ func ScanTermMaximum() *ScanTerm

+ func ScanTermMinimum() *ScanTerm

+ type ScanType interface

type ThresholdLoggingOptions

+ KVScanThreshold time.Duration

type ThresholdLoggingTracer

+ KVScanThreshold time.Duration

type TimeoutsConfig

+ KVScanTimeout time.Duration

v2.6.0

Oct 20, 2022

Changes in this version

+ type ClusterConfigProfile string

+ const ClusterConfigProfileWanDevelopment

type ClusterOptions

+ func (opts *ClusterOptions) ApplyProfile(profile ClusterConfigProfile) error

v2.5.4

Oct 27, 2022

v2.5.3

Sep 21, 2022

Changes in this version

+ const TransactionErrorReasonSuccess

+ const TransactionErrorReasonTransactionCommitAmbiguous

+ const TransactionErrorReasonTransactionExpired

+ const TransactionErrorReasonTransactionFailed

+ const TransactionErrorReasonTransactionFailedPostCommit

+ type TransactionErrorReason uint8

+ type TransactionsBucketProviderFn func(bucket string) (*Bucket, string, error)

+ type TransactionsLostCleanupKeyspaceProviderFn func() ([]TransactionKeyspace, error)

v2.5.2

Jul 20, 2022

Changes in this version

+ type TransactionLogItem struct

+ Level LogLevel

+ func (item TransactionLogItem) String() string

+ type TransactionLogger interface

+ Logs func() []TransactionLogItem

type TransactionResult

+ Logs []TransactionLogItem

v2.5.1

Jun 22, 2022

Changes in this version

+ type ChangePasswordOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

type QueryOptions

+ AsTransaction *SingleQueryTransactionOptions

+ type SingleQueryTransactionOptions struct

+ DurabilityLevel DurabilityLevel

+ Internal struct{ ... }

type TransactionOperationFailedError

+ func (tfe TransactionOperationFailedError) InternalUnwrap() error

type UserManager

+ func (um *UserManager) ChangePassword(newPassword string, opts *ChangePasswordOptions) error

v2.5.0

Apr 28, 2022

Changes in this version

type ClusterOptions

+ CompressionConfig CompressionConfig

+ type CompressionConfig struct

+ Disabled bool

+ MinRatio float64

+ MinSize uint32

type TransactionOptions

+ Internal struct{ ... }

type TransactionsInternal

+ func (t *TransactionsInternal) CleanupLocations() []gocbcore.TransactionLostATRLocation

v2.4.1

Mar 16, 2022

Changes in this version

+ var QueryErrorRetryable = RetryReason(gocbcore.QueryErrorRetryable)

type Cluster

+ func (c *Cluster) Internal() *InternalCluster

+ type GetNodesMetadataOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type InternalCluster struct

+ func (ic *InternalCluster) GetNodesMetadata(opts *GetNodesMetadataOptions) ([]NodeMetadata, error)

type LoggingMeter

+ func NewLoggingMeter(opts *LoggingMeterOptions) *LoggingMeter

+ type LoggingMeterOptions struct

+ EmitInterval time.Duration

+ type NodeMetadata struct

+ ClusterCompatibility int

+ ClusterMembership string

+ CouchAPIBase string

+ Hostname string

+ InterestingStats map[string]float64

+ MCDMemoryAllocated float64

+ MCDMemoryReserved float64

+ MemoryFree float64

+ MemoryTotal float64

+ OS string

+ Ports map[string]int

+ Status string

+ ThisNode bool

+ Uptime int

+ Version string

type QueryErrorDesc

+ Reason map[string]interface{}

+ Retry bool

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

v2.4.0

Feb 16, 2022

Changes in this version

+ const TransactionAttemptStateAborted

+ const TransactionAttemptStateCommitted

+ const TransactionAttemptStateCommitting

+ const TransactionAttemptStateCompleted

+ const TransactionAttemptStateNothingWritten

+ const TransactionAttemptStatePending

+ const TransactionAttemptStateRolledBack

+ var ErrAmbiguous = gocbcore.ErrAmbiguous

+ var ErrAtrEntryNotFound = gocbcore.ErrAtrEntryNotFound

+ var ErrAtrFull = gocbcore.ErrAtrFull

+ var ErrAtrNotFound = gocbcore.ErrAtrNotFound

+ var ErrAttemptExpired = gocbcore.ErrAttemptExpired

+ var ErrAttemptNotFoundOnQuery = errors.New("transactionAttempt not found on query")

+ var ErrDocAlreadyInTransaction = gocbcore.ErrDocAlreadyInTransaction

+ var ErrForwardCompatibilityFailure = gocbcore.ErrForwardCompatibilityFailure

+ var ErrHard = gocbcore.ErrHard

+ var ErrIllegalState = gocbcore.ErrIllegalState

+ var ErrOther = gocbcore.ErrOther

+ var ErrPreviousOperationFailed = gocbcore.ErrPreviousOperationFailed

+ var ErrTransactionAbortedExternally = gocbcore.ErrTransactionAbortedExternally

+ var ErrTransient = gocbcore.ErrTransient

+ var ErrWriteWriteConflict = gocbcore.ErrWriteWriteConflict

+ func TransactionsProtocolExtensions() []string

+ func TransactionsProtocolVersion() string

+ type AttemptFunc func(*TransactionAttemptContext) error

type BuildDeferredQueryIndexOptions

+ CollectionName string

+ ScopeName string

type Cluster

+ func (c *Cluster) Transactions() *Transactions

type ClusterOptions

+ TransactionsConfig TransactionsConfig

type CreatePrimaryQueryIndexOptions

+ CollectionName string

+ ScopeName string

type CreateQueryIndexOptions

+ CollectionName string

+ ScopeName string

type DropPrimaryQueryIndexOptions

+ CollectionName string

+ ScopeName string

type DropQueryIndexOptions

+ CollectionName string

+ ScopeName string

type DurabilityLevel

+ const DurabilityLevelUnknown

type GetAllQueryIndexesOptions

+ CollectionName string

+ ScopeName string

+ type InternalTransactionAttemptContext struct

+ func (iac *InternalTransactionAttemptContext) IsExpired() bool

+ type LostTransactionsCleaner interface

+ Close func()

+ ProcessATR func(bucket *Bucket, collection, scope, atrID string) ([]TransactionCleanupAttempt, TransactionsProcessATRStats)

+ ProcessClient func(bucket *Bucket, collection, scope, clientUUID string) (*TransactionsClientRecordDetails, error)

+ RemoveClient func(uuid string) error

+ func NewLostTransactionsCleanup(agentProvider gocbcore.TransactionsBucketAgentProviderFn, ...) LostTransactionsCleaner

type QueryIndex

+ BucketName string

+ CollectionName string

+ ScopeName string

type QueryOptions

+ PreserveExpiry bool

+ type TransactionAttemptContext struct

+ func (c *TransactionAttemptContext) Get(collection *Collection, id string) (*TransactionGetResult, error)

+ func (c *TransactionAttemptContext) Insert(collection *Collection, id string, value interface{}) (*TransactionGetResult, error)

+ func (c *TransactionAttemptContext) Internal() *InternalTransactionAttemptContext

+ func (c *TransactionAttemptContext) Query(statement string, options *TransactionQueryOptions) (*TransactionQueryResult, error)

+ func (c *TransactionAttemptContext) Remove(doc *TransactionGetResult) error

+ func (c *TransactionAttemptContext) Replace(doc *TransactionGetResult, value interface{}) (*TransactionGetResult, error)

+ type TransactionAttemptState int

+ type TransactionCleanupAttempt struct

+ AtrBucketName string

+ AtrCollectionName string

+ AtrID string

+ AtrScopeName string

+ AttemptID string

+ IsReqular bool

+ Request *TransactionCleanupRequest

+ Success bool

+ type TransactionCleanupHooks interface

+ BeforeATRGet func(id string) error

+ BeforeATRRemove func(id string) error

+ BeforeCommitDoc func(id string) error

+ BeforeDocGet func(id string) error

+ BeforeRemoveDoc func(id string) error

+ BeforeRemoveDocStagedForRemoval func(id string) error

+ BeforeRemoveLinks func(id string) error

+ type TransactionCleanupRequest struct

+ AtrBucketName string

+ AtrCollectionName string

+ AtrID string

+ AtrScopeName string

+ AttemptID string

+ ForwardCompat map[string][]TransactionsForwardCompatibilityEntry

+ Inserts []TransactionDocRecord

+ Removes []TransactionDocRecord

+ Replaces []TransactionDocRecord

+ State TransactionAttemptState

+ type TransactionClientRecordHooks interface

+ BeforeCreateRecord func() error

+ BeforeGetRecord func() error

+ BeforeRemoveClient func() error

+ BeforeUpdateCAS func() error

+ BeforeUpdateRecord func() error

+ type TransactionCommitAmbiguousError struct

+ func (tfe TransactionCommitAmbiguousError) Error() string

+ func (tfe TransactionCommitAmbiguousError) Result() *TransactionResult

+ func (tfe TransactionCommitAmbiguousError) Unwrap() error

+ type TransactionDocRecord struct

+ BucketName string

+ CollectionName string

+ ID string

+ ScopeName string

+ type TransactionExpiredError struct

+ func (tfe TransactionExpiredError) Error() string

+ func (tfe TransactionExpiredError) Result() *TransactionResult

+ func (tfe TransactionExpiredError) Unwrap() error

+ type TransactionFailedError struct

+ func (tfe TransactionFailedError) Error() string

+ func (tfe TransactionFailedError) Result() *TransactionResult

+ func (tfe TransactionFailedError) Unwrap() error

+ type TransactionFailedPostCommit struct

+ func (tfe TransactionFailedPostCommit) Error() string

+ func (tfe TransactionFailedPostCommit) Result() *TransactionResult

+ func (tfe TransactionFailedPostCommit) Unwrap() error

+ type TransactionGetResult struct

+ func (d *TransactionGetResult) Content(valuePtr interface{}) error

+ type TransactionHooks interface

+ AfterATRAborted func(ctx TransactionAttemptContext) error

+ AfterATRCommit func(ctx TransactionAttemptContext) error

+ AfterATRComplete func(ctx TransactionAttemptContext) error

+ AfterATRPending func(ctx TransactionAttemptContext) error

+ AfterATRRolledBack func(ctx TransactionAttemptContext) error

+ AfterDocCommitted func(ctx TransactionAttemptContext, docID string) error

+ AfterDocCommittedBeforeSavingCAS func(ctx TransactionAttemptContext, docID string) error

+ AfterDocRemovedPostRetry func(ctx TransactionAttemptContext, docID string) error

+ AfterDocRemovedPreRetry func(ctx TransactionAttemptContext, docID string) error

+ AfterDocsCommitted func(ctx TransactionAttemptContext) error

+ AfterDocsRemoved func(ctx TransactionAttemptContext) error

+ AfterGetComplete func(ctx TransactionAttemptContext, docID string) error

+ AfterQuery func(ctx TransactionAttemptContext, statement string) error

+ AfterRemoveStagedInsert func(ctx TransactionAttemptContext, docID string) error

+ AfterRollbackDeleteInserted func(ctx TransactionAttemptContext, docID string) error

+ AfterRollbackReplaceOrRemove func(ctx TransactionAttemptContext, docID string) error

+ AfterStagedInsertComplete func(ctx TransactionAttemptContext, docID string) error

+ AfterStagedRemoveComplete func(ctx TransactionAttemptContext, docID string) error

+ AfterStagedReplaceComplete func(ctx TransactionAttemptContext, docID string) error

+ BeforeATRAborted func(ctx TransactionAttemptContext) error

+ BeforeATRCommit func(ctx TransactionAttemptContext) error

+ BeforeATRCommitAmbiguityResolution func(ctx TransactionAttemptContext) error

+ BeforeATRComplete func(ctx TransactionAttemptContext) error

+ BeforeATRPending func(ctx TransactionAttemptContext) error

+ BeforeATRRolledBack func(ctx TransactionAttemptContext) error

+ BeforeCheckATREntryForBlockingDoc func(ctx TransactionAttemptContext, docID string) error

+ BeforeDocCommitted func(ctx TransactionAttemptContext, docID string) error

+ BeforeDocGet func(ctx TransactionAttemptContext, docID string) error

+ BeforeDocRemoved func(ctx TransactionAttemptContext, docID string) error

+ BeforeDocRolledBack func(ctx TransactionAttemptContext, docID string) error

+ BeforeGetDocInExistsDuringStagedInsert func(ctx TransactionAttemptContext, docID string) error

+ BeforeQuery func(ctx TransactionAttemptContext, statement string) error

+ BeforeRemoveStagedInsert func(ctx TransactionAttemptContext, docID string) error

+ BeforeRemovingDocDuringStagedInsert func(ctx TransactionAttemptContext, docID string) error

+ BeforeRollbackDeleteInserted func(ctx TransactionAttemptContext, docID string) error

+ BeforeStagedInsert func(ctx TransactionAttemptContext, docID string) error

+ BeforeStagedRemove func(ctx TransactionAttemptContext, docID string) error

+ BeforeStagedReplace func(ctx TransactionAttemptContext, docID string) error

+ HasExpiredClientSideHook func(ctx TransactionAttemptContext, stage string, vbID string) (bool, error)

+ RandomATRIDForVbucket func(ctx TransactionAttemptContext) (string, error)

+ type TransactionKeyspace struct

+ BucketName string

+ CollectionName string

+ ScopeName string

+ type TransactionOperationFailedError struct

+ func (tfe *TransactionOperationFailedError) ErrorClass() gocbcore.TransactionErrorClass

+ func (tfe TransactionOperationFailedError) Error() string

+ func (tfe TransactionOperationFailedError) Retry() bool

+ func (tfe TransactionOperationFailedError) Rollback() bool

+ func (tfe TransactionOperationFailedError) ToRaise() gocbcore.TransactionErrorReason

+ func (tfe TransactionOperationFailedError) Unwrap() error

+ type TransactionOptions struct

+ DurabilityLevel DurabilityLevel

+ MetadataCollection *Collection

+ Timeout time.Duration

+ type TransactionQueryOptions struct

+ ClientContextID string

+ FlexIndex bool

+ NamedParameters map[string]interface{}

+ PipelineBatch uint32

+ PipelineCap uint32

+ PositionalParameters []interface{}

+ Prepared bool

+ Profile QueryProfileMode

+ Raw map[string]interface{}

+ Readonly bool

+ ScanCap uint32

+ ScanConsistency QueryScanConsistency

+ ScanWait time.Duration

+ Scope *Scope

+ type TransactionQueryResult struct

+ func (r *TransactionQueryResult) MetaData() (*QueryMetaData, error)

+ func (r *TransactionQueryResult) Next() bool

+ func (r *TransactionQueryResult) One(valuePtr interface{}) error

+ func (r *TransactionQueryResult) Row(valuePtr interface{}) error

+ type TransactionResult struct

+ TransactionID string

+ UnstagingComplete bool

+ type Transactions struct

+ func (t *Transactions) Internal() *TransactionsInternal

+ func (t *Transactions) Run(logicFn AttemptFunc, perConfig *TransactionOptions) (*TransactionResult, error)

+ type TransactionsCleaner interface

+ AddRequest func(req *TransactionCleanupRequest) bool

+ CleanupAttempt func(bucket *Bucket, isRegular bool, req *TransactionCleanupRequest) TransactionCleanupAttempt

+ Close func()

+ ForceCleanupQueue func() []TransactionCleanupAttempt

+ PopRequest func() *TransactionCleanupRequest

+ QueueLength func() int32

+ func NewTransactionsCleaner(agentProvider gocbcore.TransactionsBucketAgentProviderFn, ...) TransactionsCleaner

+ type TransactionsCleanupConfig struct

+ CleanupCollections []TransactionKeyspace

+ CleanupQueueSize uint32

+ CleanupWindow time.Duration

+ DisableClientAttemptCleanup bool

+ DisableLostAttemptCleanup bool

+ type TransactionsClientRecordDetails 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 TransactionsConfig struct

+ CleanupConfig TransactionsCleanupConfig

+ DurabilityLevel DurabilityLevel

+ Internal struct{ ... }

+ MetadataCollection *TransactionKeyspace

+ QueryConfig TransactionsQueryConfig

+ Timeout time.Duration

+ type TransactionsForwardCompatibilityEntry struct

+ Behaviour string

+ ProtocolExtension string

+ ProtocolVersion string

+ RetryInterval int

+ type TransactionsInternal struct

+ func (t *TransactionsInternal) CleanupQueueLength() int32

+ func (t *TransactionsInternal) ClientCleanupEnabled() bool

+ func (t *TransactionsInternal) ForceCleanupQueue() []TransactionCleanupAttempt

+ type TransactionsProcessATRStats struct

+ NumEntries int

+ NumEntriesExpired int

+ type TransactionsQueryConfig struct

+ ScanConsistency QueryScanConsistency

type WatchQueryIndexOptions

+ CollectionName string

+ ScopeName string

v2.3.5

Dec 14, 2021

Changes in this version

+ var ErrQuotaLimitedFailure = gocbcore.ErrQuotaLimitedFailure

+ var ErrRateLimitedFailure = gocbcore.ErrRateLimitedFailure

type AnalyticsError

+ ErrorText string

+ HTTPStatusCode int

type BucketSettings

+ StorageBackend StorageBackend

type ConflictResolutionType

+ const ConflictResolutionTypeCustom

type HTTPError

+ StatusCode uint32

type QueryError

+ ErrorText string

+ HTTPStatusCode int

type QueryResult

+ func (r *QueryResult) Internal() *QueryResultInternal

+ type QueryResultInternal struct

+ func (r *QueryResultInternal) Endpoint() string

type SearchError

+ HTTPStatusCode int

type SearchOptions

+ IncludeLocations bool

+ type StorageBackend string

+ const StorageBackendCouchstore

+ const StorageBackendMagma

type ViewError

+ ErrorText string

+ HTTPStatusCode int

v2.3.4

Nov 16, 2021

Changes in this version

+ var ErrQuotaLimitingFailure = gocbcore.ErrQuotaLimitingFailure

+ var ErrRateLimitingFailure = gocbcore.ErrRateLimitingFailure

type HTTPError

+ ErrorText string

type QueryError

+ ResponseBody string

v2.3.3

Oct 19, 2021

v2.3.2

Sep 21, 2021

Changes in this version

+ var ErrEventingFunctionCompilationFailure = gocbcore.ErrEventingFunctionCompilationFailure

+ var ErrEventingFunctionDeployed = gocbcore.ErrEventingFunctionNotUndeployed

+ var ErrEventingFunctionIdenticalKeyspace = gocbcore.ErrEventingFunctionIdenticalKeyspace

+ var ErrEventingFunctionNotBootstrapped = gocbcore.ErrEventingFunctionNotBootstrapped

+ var ErrEventingFunctionNotDeployed = gocbcore.ErrEventingFunctionNotDeployed

+ var ErrEventingFunctionNotFound = gocbcore.ErrEventingFunctionNotFound

type Cluster

+ func (c *Cluster) EventingFunctions() *EventingFunctionManager

+ type DeployEventingFunctionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropEventingFunctionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type EventingFunction struct

+ BucketBindings []EventingFunctionBucketBinding

+ Code string

+ ConstantBindings []EventingFunctionConstantBinding

+ EnforceSchema bool

+ FunctionInstanceID string

+ HandlerUUID int

+ MetadataKeyspace EventingFunctionKeyspace

+ Name string

+ Settings EventingFunctionSettings

+ SourceKeyspace EventingFunctionKeyspace

+ UrlBindings []EventingFunctionUrlBinding

+ Version string

+ func (ef *EventingFunction) UnmarshalJSON(b []byte) error

+ func (ef EventingFunction) MarshalJSON() ([]byte, error)

+ type EventingFunctionBucketAccess string

+ var EventingFunctionBucketAccessReadOnly EventingFunctionBucketAccess = "r"

+ var EventingFunctionBucketAccessReadWrite EventingFunctionBucketAccess = "rw"

+ type EventingFunctionBucketBinding struct

+ Access EventingFunctionBucketAccess

+ Alias string

+ Name EventingFunctionKeyspace

+ type EventingFunctionConstantBinding struct

+ Alias string

+ Literal string

+ type EventingFunctionDCPBoundary string

+ var EventingFunctionDCPBoundaryEverything EventingFunctionDCPBoundary = "everything"

+ var EventingFunctionDCPBoundaryFromNow EventingFunctionDCPBoundary = "from_now"

+ type EventingFunctionDeploymentStatus bool

+ var EventingFunctionDeploymentStatusDeployed EventingFunctionDeploymentStatus = true

+ var EventingFunctionDeploymentStatusUndeployed EventingFunctionDeploymentStatus = false

+ type EventingFunctionKeyspace struct

+ Bucket string

+ Collection string

+ Scope string

+ type EventingFunctionLanguageCompatibility string

+ var EventingFunctionLanguageCompatibilityVersion600 EventingFunctionLanguageCompatibility = "6.0.0"

+ var EventingFunctionLanguageCompatibilityVersion650 EventingFunctionLanguageCompatibility = "6.5.0"

+ var EventingFunctionLanguageCompatibilityVersion662 EventingFunctionLanguageCompatibility = "6.6.2"

+ type EventingFunctionLogLevel string

+ var EventingFunctionLogLevelDebug EventingFunctionLogLevel = "DEBUG"

+ var EventingFunctionLogLevelError EventingFunctionLogLevel = "ERROR"

+ var EventingFunctionLogLevelInfo EventingFunctionLogLevel = "INFO"

+ var EventingFunctionLogLevelTrace EventingFunctionLogLevel = "TRACE"

+ var EventingFunctionLogLevelWarning EventingFunctionLogLevel = "WARNING"

+ type EventingFunctionManager struct

+ func (efm *EventingFunctionManager) DeployFunction(name string, opts *DeployEventingFunctionOptions) error

+ func (efm *EventingFunctionManager) DropFunction(name string, opts *DropEventingFunctionOptions) error

+ func (efm *EventingFunctionManager) FunctionsStatus(opts *EventingFunctionsStatusOptions) (*EventingStatus, error)

+ func (efm *EventingFunctionManager) GetAllFunctions(opts *GetAllEventingFunctionsOptions) ([]EventingFunction, error)

+ func (efm *EventingFunctionManager) GetFunction(name string, opts *GetEventingFunctionOptions) (*EventingFunction, error)

+ func (efm *EventingFunctionManager) PauseFunction(name string, opts *PauseEventingFunctionOptions) error

+ func (efm *EventingFunctionManager) ResumeFunction(name string, opts *ResumeEventingFunctionOptions) error

+ func (efm *EventingFunctionManager) UndeployFunction(name string, opts *UndeployEventingFunctionOptions) error

+ func (efm *EventingFunctionManager) UpsertFunction(function EventingFunction, opts *UpsertEventingFunctionOptions) error

+ type EventingFunctionProcessingStatus bool

+ var EventingFunctionProcessingStatusPaused EventingFunctionProcessingStatus = false

+ var EventingFunctionProcessingStatusRunning EventingFunctionProcessingStatus = true

+ type EventingFunctionSettings struct

+ AppLogDir string

+ AppLogMaxFiles int

+ AppLogMaxSize int

+ BucketCacheAge int

+ BucketCacheSize int

+ CPPWorkerThreadCount int

+ CheckpointInterval time.Duration

+ CurlMaxAllowedRespSize int

+ DCPStreamBoundary EventingFunctionDCPBoundary

+ DeploymentStatus EventingFunctionDeploymentStatus

+ Description string

+ EnableAppLogRotation bool

+ ExecutionTimeout time.Duration

+ HandlerFooters []string

+ HandlerHeaders []string

+ LCBInstCapacity int

+ LCBRetryCount int

+ LCBTimeout time.Duration

+ LanguageCompatibility EventingFunctionLanguageCompatibility

+ LogLevel EventingFunctionLogLevel

+ NumTimerPartitions int

+ ProcessingStatus EventingFunctionProcessingStatus

+ QueryConsistency QueryScanConsistency

+ QueryPrepareAll bool

+ SockBatchSize int

+ TickDuration time.Duration

+ TimerContextSize int

+ UserPrefix string

+ WorkerCount int

+ type EventingFunctionState struct

+ DeploymentStatus EventingFunctionDeploymentStatus

+ Name string

+ NumBootstrappingNodes int

+ NumDeployedNodes int

+ ProcessingStatus EventingFunctionProcessingStatus

+ Status EventingFunctionStatus

+ type EventingFunctionStatus string

+ var EventingFunctionStateDeployed EventingFunctionStatus = "deployed"

+ var EventingFunctionStateDeploying EventingFunctionStatus = "deploying"

+ var EventingFunctionStatePaused EventingFunctionStatus = "paused"

+ var EventingFunctionStatePausing EventingFunctionStatus = "pausing"

+ var EventingFunctionStateUndeployed EventingFunctionStatus = "undeployed"

+ var EventingFunctionStateUndeploying EventingFunctionStatus = "undeploying"

+ type EventingFunctionUrlAuth interface

+ Key func() string

+ Method func() string

+ Password func() string

+ Username func() string

+ type EventingFunctionUrlAuthBasic struct

+ Pass string

+ User string

+ func (ua EventingFunctionUrlAuthBasic) Key() string

+ func (ua EventingFunctionUrlAuthBasic) Method() string

+ func (ua EventingFunctionUrlAuthBasic) Password() string

+ func (ua EventingFunctionUrlAuthBasic) Username() string

+ type EventingFunctionUrlAuthBearer struct

+ BearerKey string

+ func (ua EventingFunctionUrlAuthBearer) Key() string

+ func (ua EventingFunctionUrlAuthBearer) Method() string

+ func (ua EventingFunctionUrlAuthBearer) Password() string

+ func (ua EventingFunctionUrlAuthBearer) Username() string

+ type EventingFunctionUrlAuthDigest struct

+ Pass string

+ User string

+ func (ua EventingFunctionUrlAuthDigest) Key() string

+ func (ua EventingFunctionUrlAuthDigest) Method() string

+ func (ua EventingFunctionUrlAuthDigest) Password() string

+ func (ua EventingFunctionUrlAuthDigest) Username() string

+ type EventingFunctionUrlBinding struct

+ Alias string

+ AllowCookies bool

+ Auth EventingFunctionUrlAuth

+ Hostname string

+ ValidateSSLCertificate bool

+ type EventingFunctionUrlNoAuth struct

+ func (ua EventingFunctionUrlNoAuth) Key() string

+ func (ua EventingFunctionUrlNoAuth) Method() string

+ func (ua EventingFunctionUrlNoAuth) Password() string

+ func (ua EventingFunctionUrlNoAuth) Username() string

+ type EventingFunctionsStatusOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type EventingStatus struct

+ Functions []EventingFunctionState

+ NumEventingNodes int

+ func (ef *EventingStatus) UnmarshalJSON(b []byte) error

+ type GetAllEventingFunctionsOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetEventingFunctionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type PauseEventingFunctionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type ResumeEventingFunctionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

type ServiceType

+ const ServiceTypeEventing

+ type UndeployEventingFunctionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type UpsertEventingFunctionOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

v2.3.1

Aug 17, 2021

Changes in this version

type AnalyticsOptions

+ Internal struct{ ... }

type QueryOptions

+ Internal struct{ ... }

type SearchOptions

+ Internal struct{ ... }

type ViewOptions

+ Internal struct{ ... }

v2.3.0

Jul 15, 2021

Changes in this version

+ var ErrAnalyticsLinkExists = errors.New("analytics clink already exists")

+ type AggregatingMeterOptions struct

+ EmitInterval time.Duration

type AllowQueryingSearchIndexOptions

+ ParentSpan RequestSpan

+ type AnalyticsEncryptionLevel uint8

+ const AnalyticsEncryptionLevelFull

+ const AnalyticsEncryptionLevelHalf

+ const AnalyticsEncryptionLevelNone

+ func (ael AnalyticsEncryptionLevel) String() string

type AnalyticsIndexManager

+ func (am *AnalyticsIndexManager) CreateLink(link AnalyticsLink, opts *CreateAnalyticsLinkOptions) error

+ func (am *AnalyticsIndexManager) DropLink(linkName, dataverseName string, opts *DropAnalyticsLinkOptions) error

+ func (am *AnalyticsIndexManager) GetLinks(opts *GetAnalyticsLinksOptions) ([]AnalyticsLink, error)

+ func (am *AnalyticsIndexManager) ReplaceLink(link AnalyticsLink, opts *ReplaceAnalyticsLinkOptions) error

+ type AnalyticsLink interface

+ DataverseName func() string

+ FormEncode func() ([]byte, error)

+ LinkType func() AnalyticsLinkType

+ Name func() string

+ Validate func() error

+ type AnalyticsLinkType string

+ const AnalyticsLinkTypeAzureExternal

+ const AnalyticsLinkTypeCouchbaseRemote

+ const AnalyticsLinkTypeS3External

type AnalyticsOptions

+ Context context.Context

+ ParentSpan RequestSpan

type AnalyzeDocumentOptions

+ ParentSpan RequestSpan

type AppendOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type AzureBlobExternalAnalyticsLink struct

+ AccountKey string

+ AccountName string

+ BlobEndpoint string

+ ConnectionString string

+ Dataverse string

+ EndpointSuffix string

+ LinkName string

+ SharedAccessSignature string

+ func NewAzureBlobExternalAnalyticsLink(linkName, dataverseName string, opts *NewAzureBlobExternalAnalyticsLinkOptions) *AzureBlobExternalAnalyticsLink

+ func (al *AzureBlobExternalAnalyticsLink) DataverseName() string

+ func (al *AzureBlobExternalAnalyticsLink) FormEncode() ([]byte, error)

+ func (al *AzureBlobExternalAnalyticsLink) LinkType() AnalyticsLinkType

+ func (al *AzureBlobExternalAnalyticsLink) Name() string

+ func (al *AzureBlobExternalAnalyticsLink) Validate() error

type BuildDeferredQueryIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

type BulkOpOptions

+ Context context.Context

+ ParentSpan RequestSpan

type ClusterOptions

+ Meter Meter

type ConnectAnalyticsLinkOptions

+ Context context.Context

+ DataverseName string

+ ParentSpan RequestSpan

+ type CouchbaseRemoteAnalyticsEncryptionSettings struct

+ Certificate []byte

+ ClientCertificate []byte

+ ClientKey []byte

+ EncryptionLevel AnalyticsEncryptionLevel

+ type CouchbaseRemoteAnalyticsLink struct

+ Dataverse string

+ Encryption CouchbaseRemoteAnalyticsEncryptionSettings

+ Hostname string

+ LinkName string

+ Password string

+ Username string

+ func NewCouchbaseRemoteAnalyticsLink(linkName, hostname, dataverseName string, ...) *CouchbaseRemoteAnalyticsLink

+ func (al *CouchbaseRemoteAnalyticsLink) DataverseName() string

+ func (al *CouchbaseRemoteAnalyticsLink) FormEncode() ([]byte, error)

+ func (al *CouchbaseRemoteAnalyticsLink) LinkType() AnalyticsLinkType

+ func (al *CouchbaseRemoteAnalyticsLink) Name() string

+ func (al *CouchbaseRemoteAnalyticsLink) Validate() error

+ type Counter interface

+ IncrementBy func(num uint64)

type CreateAnalyticsDatasetOptions

+ Context context.Context

+ ParentSpan RequestSpan

type CreateAnalyticsDataverseOptions

+ Context context.Context

+ ParentSpan RequestSpan

type CreateAnalyticsIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type CreateAnalyticsLinkOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

type CreateBucketOptions

+ Context context.Context

+ ParentSpan RequestSpan

type CreateCollectionOptions

+ Context context.Context

+ ParentSpan RequestSpan

type CreatePrimaryQueryIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

type CreateQueryIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

type CreateScopeOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DecrementOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DisallowQueryingSearchIndexOptions

+ ParentSpan RequestSpan

type DisconnectAnalyticsLinkOptions

+ Context context.Context

+ DataverseName string

+ ParentSpan RequestSpan

type DropAnalyticsDatasetOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropAnalyticsDataverseOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropAnalyticsIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type DropAnalyticsLinkOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

type DropBucketOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropCollectionOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropDesignDocumentOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropGroupOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropPrimaryQueryIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropQueryIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropScopeOptions

+ Context context.Context

+ ParentSpan RequestSpan

type DropSearchIndexOptions

+ ParentSpan RequestSpan

type DropUserOptions

+ Context context.Context

+ ParentSpan RequestSpan

type ExistsOptions

+ Context context.Context

+ ParentSpan RequestSpan

type FlushBucketOptions

+ Context context.Context

+ ParentSpan RequestSpan

type FreezePlanSearchIndexOptions

+ ParentSpan RequestSpan

type GetAllAnalyticsDatasetsOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllAnalyticsIndexesOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllBucketsOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllDesignDocumentsOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllGroupsOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllQueryIndexesOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllReplicaOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllScopesOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAllSearchIndexOptions

+ ParentSpan RequestSpan

type GetAllUsersOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type GetAnalyticsLinksOptions struct

+ Context context.Context

+ Dataverse string

+ LinkType AnalyticsLinkType

+ Name string

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

type GetAndLockOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAndTouchOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetAnyReplicaOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetBucketOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetDesignDocumentOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetGroupOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetIndexedDocumentsCountOptions

+ ParentSpan RequestSpan

type GetOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetPendingMutationsAnalyticsOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetRolesOptions

+ Context context.Context

+ ParentSpan RequestSpan

type GetSearchIndexOptions

+ ParentSpan RequestSpan

type GetUserOptions

+ Context context.Context

+ ParentSpan RequestSpan

type IncrementOptions

+ Context context.Context

+ ParentSpan RequestSpan

type InsertOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type LoggingMeter struct

+ func NewAggregatingMeter(opts *AggregatingMeterOptions) *LoggingMeter

+ func (am *LoggingMeter) Counter(_ string, _ map[string]string) (Counter, error)

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

type LookupInOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type Meter interface

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

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

type MutateInOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ PreserveExpiry bool

+ type NewAzureBlobExternalAnalyticsLinkOptions struct

+ AccountKey string

+ AccountName string

+ BlobEndpoint string

+ ConnectionString string

+ EndpointSuffix string

+ SharedAccessSignature string

+ type NewCouchbaseRemoteAnalyticsLinkOptions struct

+ Encryption CouchbaseRemoteAnalyticsEncryptionSettings

+ Password string

+ Username string

+ type NewS3ExternalAnalyticsLinkOptions struct

+ ServiceEndpoint string

+ SessionToken string

+ type NoopMeter struct

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

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

+ type NoopTracer struct

+ func (tracer *NoopTracer) RequestSpan(parentContext RequestSpanContext, operationName string) RequestSpan

type PauseIngestSearchIndexOptions

+ ParentSpan RequestSpan

type PingOptions

+ Context context.Context

+ ParentSpan RequestSpan

type PrependOptions

+ Context context.Context

+ ParentSpan RequestSpan

type PublishDesignDocumentOptions

+ Context context.Context

+ ParentSpan RequestSpan

type QueryOptions

+ Context context.Context

+ ParentSpan RequestSpan

type RemoveOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type ReplaceAnalyticsLinkOptions struct

+ Context context.Context

+ ParentSpan RequestSpan

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

type ReplaceOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ PreserveExpiry bool

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

+ ParentSpan RequestSpan

+ type S3ExternalAnalyticsLink struct

+ AccessKeyID string

+ Dataverse string

+ LinkName string

+ Region string

+ SecretAccessKey string

+ ServiceEndpoint string

+ SessionToken string

+ func NewS3ExternalAnalyticsLink(linkName, dataverseName, accessKeyID, secretAccessKey, region string, ...) *S3ExternalAnalyticsLink

+ func (al *S3ExternalAnalyticsLink) DataverseName() string

+ func (al *S3ExternalAnalyticsLink) FormEncode() ([]byte, error)

+ func (al *S3ExternalAnalyticsLink) LinkType() AnalyticsLinkType

+ func (al *S3ExternalAnalyticsLink) Name() string

+ func (al *S3ExternalAnalyticsLink) Validate() error

type SearchOptions

+ Context context.Context

+ ParentSpan RequestSpan

type ThresholdLoggingTracer

+ func (t *ThresholdLoggingTracer) RequestSpan(parentContext RequestSpanContext, operationName string) RequestSpan

type TouchOptions

+ Context context.Context

+ ParentSpan RequestSpan

type UnfreezePlanSearchIndexOptions

+ ParentSpan RequestSpan

type UnlockOptions

+ Context context.Context

+ ParentSpan RequestSpan

type UpdateBucketOptions

+ Context context.Context

+ ParentSpan RequestSpan

type UpsertDesignDocumentOptions

+ Context context.Context

+ ParentSpan RequestSpan

type UpsertGroupOptions

+ Context context.Context

+ ParentSpan RequestSpan

type UpsertOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ PreserveExpiry bool

type UpsertSearchIndexOptions

+ ParentSpan RequestSpan

type UpsertUserOptions

+ Context context.Context

+ ParentSpan RequestSpan

+ type ValueRecorder interface

+ RecordValue func(val uint64)

type ViewOptions

+ Context context.Context

+ ParentSpan RequestSpan

type WaitUntilReadyOptions

+ Context context.Context

+ RetryStrategy RetryStrategy

type WatchQueryIndexOptions

+ Context context.Context

+ ParentSpan RequestSpan

v2.2.5

Aug 18, 2021

v2.2.4

Jun 15, 2021

v2.2.3

Apr 20, 2021

v2.2.2

Mar 16, 2021

Changes in this version

+ type Capability uint32

+ const CapabilityCreateAsDeleted

+ const CapabilityDurableWrites

+ const CapabilityReplaceBodyWithXattr

+ type CapabilityStatus uint32

+ const CapabilityStatusSupported

+ const CapabilityStatusUnknown

+ const CapabilityStatusUnsupported

type InternalBucket

+ func (ib *InternalBucket) CapabilityStatus(cap Capability) (CapabilityStatus, error)

type QueryIndex

+ Partition string

type SearchOptions

+ Collections []string

v2.2.1

Feb 16, 2021

Changes in this version

type AnalyticsError

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

type HTTPError

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

type KeyValueError

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

type QueryError

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

type SearchError

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

type SubdocDocFlag

+ const SubdocDocFlagCreateAsDeleted

type ViewError

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

v2.2.0

Dec 15, 2020

Changes in this version

type AnalyticsResult

+ func (r *AnalyticsResult) Raw() *AnalyticsResultRaw

+ type AnalyticsResultRaw struct

+ func (arr *AnalyticsResultRaw) Close() error

+ func (arr *AnalyticsResultRaw) Err() error

+ func (arr *AnalyticsResultRaw) MetaData() ([]byte, error)

+ func (arr *AnalyticsResultRaw) NextBytes() []byte

type AppendOptions

+ Internal struct{ ... }

type BucketSettings

+ MaxExpiry time.Duration

+ MinimumDurabilityLevel DurabilityLevel

type DecrementOptions

+ Internal struct{ ... }

type DurabilityLevel

+ const DurabilityLevelNone

type ExistsOptions

+ Internal struct{ ... }

type GetAllReplicaOptions

+ Internal struct{ ... }

type GetAndLockOptions

+ Internal struct{ ... }

type GetAndTouchOptions

+ Internal struct{ ... }

type GetAnyReplicaOptions

+ Internal struct{ ... }

type GetOptions

+ Internal struct{ ... }

type IncrementOptions

+ Internal struct{ ... }

type InsertOptions

+ Internal struct{ ... }

type PrependOptions

+ Internal struct{ ... }

type QueryResult

+ func (r *QueryResult) Raw() *QueryResultRaw

+ type QueryResultRaw struct

+ func (qrr *QueryResultRaw) Close() error

+ func (qrr *QueryResultRaw) Err() error

+ func (qrr *QueryResultRaw) MetaData() ([]byte, error)

+ func (qrr *QueryResultRaw) NextBytes() []byte

type RemoveOptions

+ Internal struct{ ... }

type ReplaceOptions

+ Internal struct{ ... }

type SearchOptions

+ DisableScoring bool

type SearchResult

+ func (r *SearchResult) Raw() *SearchResultRaw

+ type SearchResultRaw struct

+ func (srr *SearchResultRaw) Close() error

+ func (srr *SearchResultRaw) Err() error

+ func (srr *SearchResultRaw) MetaData() ([]byte, error)

+ func (srr *SearchResultRaw) NextBytes() []byte

type TouchOptions

+ Internal struct{ ... }

type UnlockOptions

+ Internal struct{ ... }

type UpsertOptions

+ Internal struct{ ... }

type ViewResult

+ func (r *ViewResult) Raw() *ViewResultRaw

+ type ViewResultRaw struct

+ func (vrr *ViewResultRaw) Close() error

+ func (vrr *ViewResultRaw) Err() error

+ func (vrr *ViewResultRaw) MetaData() ([]byte, error)

+ func (vrr *ViewResultRaw) NextBytes() []byte

v2.1.8

Nov 17, 2020

Changes in this version

type KeyValueError

+ DocumentID string

v2.1.7

Oct 20, 2020

Changes in this version

type QueryOptions

+ FlexIndex bool

type Role

+ Collection string

+ Scope string

type Scope

+ func (s *Scope) AnalyticsQuery(statement string, opts *AnalyticsOptions) (*AnalyticsResult, error)

+ func (s *Scope) Query(statement string, opts *QueryOptions) (*QueryResult, error)

+ type SearchDateRangeFacetResult struct

+ Count int

+ End string

+ Name string

+ Start string

type SearchFacetResult

+ DateRanges []SearchDateRangeFacetResult

+ NumericRanges []SearchNumericRangeFacetResult

+ Terms []SearchTermFacetResult

+ type SearchNumericRangeFacetResult struct

+ Count int

+ Max float64

+ Min float64

+ Name string

+ type SearchTermFacetResult struct

+ Count int

+ Term string

v2.1.6

Sep 15, 2020

Changes in this version

type GetResult

+ func (d *GetResult) ExpiryTime() time.Time

v2.1.5

Aug 18, 2020

Changes in this version

+ type SaslMechanism string

+ const PlainSaslMechanism

+ const ScramSha1SaslMechanism

+ const ScramSha256SaslMechanism

+ const ScramSha512SaslMechanism

type SecurityConfig

+ AllowedSaslMechanisms []SaslMechanism

+ type ThresholdLoggingTracer struct

+ AnalyticsThreshold time.Duration

+ Interval time.Duration

+ KVThreshold time.Duration

+ ManagementThreshold time.Duration

+ QueryThreshold time.Duration

+ SampleSize uint32

+ SearchThreshold time.Duration

+ ViewsThreshold time.Duration

+ func NewThresholdLoggingTracer(opts *ThresholdLoggingOptions) *ThresholdLoggingTracer

+ func (t *ThresholdLoggingTracer) AddRef() int32

+ func (t *ThresholdLoggingTracer) DecRef() int32

+ func (t *ThresholdLoggingTracer) StartSpan(operationName string, parentContext requestSpanContext) requestSpan

v2.1.4

Jul 21, 2020

Changes in this version

type Bucket

+ func (b *Bucket) Internal() *InternalBucket

type Collection

+ func (c *Collection) Bucket() *Bucket

+ func (c *Collection) ScopeName() string

type EvictionPolicyType

+ const EvictionPolicyTypeNoEviction

+ const EvictionPolicyTypeNotRecentlyUsed

+ type InternalBucket struct

+ func (ib *InternalBucket) IORouter() (*gocbcore.Agent, error)

type MutationState

+ func (mt *MutationState) Internal() *MutationStateInternal

+ type MutationStateInternal struct

+ func (mti *MutationStateInternal) Add(bucket string, tokens ...gocbcore.MutationToken)

+ func (mti *MutationStateInternal) Tokens() []MutationToken

type Scope

+ func (s *Scope) BucketName() string

type WaitUntilReadyOptions

+ ServiceTypes []ServiceType

v2.1.3

Jul 1, 2020

v2.1.2

Jun 16, 2020

Changes in this version

type LookupInOptions

+ Internal struct{ ... }

type MutateInOptions

+ Internal struct{ ... }

type SearchError

+ ErrorText string

+ IndexName string

v2.1.1

May 19, 2020

Changes in this version

type CollectionSpec

+ MaxExpiry time.Duration

+ 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

v2.1.0

Apr 21, 2020

Changes in this version

type Bucket

+ func (b *Bucket) WaitUntilReady(timeout time.Duration, opts *WaitUntilReadyOptions) error

type Cluster

+ func (c *Cluster) WaitUntilReady(timeout time.Duration, opts *WaitUntilReadyOptions) error

type ClusterOptions

+ InternalConfig InternalConfig

type DiagnosticsResult

+ State ClusterState

+ type InternalConfig struct

+ TLSRootCAProvider func() *x509.CertPool

type PingOptions

+ Timeout time.Duration

+ type WaitUntilReadyOptions struct

+ DesiredState ClusterState

v2.0.4

Apr 21, 2020

v2.0.3

Mar 17, 2020

Changes in this version

type Cluster

+ func (c *Cluster) Ping(opts *PingOptions) (*PingResult, error)

type KeyValueError

+ LastConnectionID string

+ LastDispatchedFrom string

+ LastDispatchedTo string

v2.0.2

Feb 21, 2020

v2.0.1

Feb 19, 2020

Changes in this version

type TimeoutsConfig

+ KVDurableTimeout time.Duration

v2.0.0

Jan 20, 2020

Changes in this version

+ const AnalyticsScanConsistencyNotBounded

+ const AnalyticsScanConsistencyRequestPlus

+ const AnsiHightlightStyle

+ const ClusterStateDegraded

+ const ClusterStateOffline

+ const ClusterStateOnline

+ const CompressionModeActive

+ const CompressionModeOff

+ const CompressionModePassive

+ const ConflictResolutionTypeSequenceNumber

+ const ConflictResolutionTypeTimestamp

+ const CouchbaseBucketType

+ const DefaultHighlightStyle

+ const DesignDocumentNamespaceDevelopment

+ const DesignDocumentNamespaceProduction

+ const DurabilityLevelMajority

+ const DurabilityLevelMajorityAndPersistOnMaster

+ const DurabilityLevelPersistToMajority

+ const EndpointStateConnected

+ const EndpointStateConnecting

+ const EndpointStateDisconnected

+ const EndpointStateDisconnecting

+ const EphemeralBucketType

+ const EvictionPolicyTypeFull

+ const EvictionPolicyTypeValueOnly

+ const HTMLHighlightStyle

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogMaxVerbosity

+ const LogSched

+ const LogTrace

+ const LogWarn

+ const MemcachedBucketType

+ const MutationMacroCAS

+ const MutationMacroSeqNo

+ const MutationMacroValueCRC32c

+ const PingStateError

+ const PingStateOk

+ const PingStateTimeout

+ const QueryIndexTypeGsi

+ const QueryIndexTypeView

+ const QueryProfileModeNone

+ const QueryProfileModePhases

+ const QueryProfileModeTimings

+ const QueryScanConsistencyNotBounded

+ const QueryScanConsistencyRequestPlus

+ const QueryStatusAborted

+ const QueryStatusClosed

+ const QueryStatusCompleted

+ const QueryStatusErrors

+ const QueryStatusFatal

+ const QueryStatusRunning

+ const QueryStatusStopped

+ const QueryStatusSuccess

+ const QueryStatusTimeout

+ const QueryStatusUnknown

+ const RedactFull

+ const RedactNone

+ const RedactPartial

+ const SearchScanConsistencyNotBounded

+ const ServiceTypeAnalytics

+ const ServiceTypeKeyValue

+ const ServiceTypeManagement

+ const ServiceTypeQuery

+ const ServiceTypeSearch

+ const ServiceTypeViews

+ const StoreSemanticsInsert

+ const StoreSemanticsReplace

+ const StoreSemanticsUpsert

+ const SubdocDocFlagAccessDeleted

+ const SubdocDocFlagAddDoc

+ const SubdocDocFlagMkDoc

+ const SubdocDocFlagNone

+ const SubdocFlagCreatePath

+ const SubdocFlagNone

+ const SubdocFlagUseMacros

+ const SubdocFlagXattr

+ const ViewErrorModeContinue

+ const ViewErrorModeStop

+ const ViewOrderingAscending

+ const ViewOrderingDescending

+ const ViewScanConsistencyNotBounded

+ const ViewScanConsistencyRequestPlus

+ const ViewScanConsistencyUpdateAfter

+ var AnalyticsTemporaryFailureRetryReason = RetryReason(gocbcore.AnalyticsTemporaryFailureRetryReason)

+ var CircuitBreakerOpenRetryReason = RetryReason(gocbcore.CircuitBreakerOpenRetryReason)

+ var ErrAmbiguousTimeout = gocbcore.ErrAmbiguousTimeout

+ var ErrAuthenticationFailure = gocbcore.ErrAuthenticationFailure

+ var ErrBucketExists = gocbcore.ErrBucketExists

+ var ErrBucketNotFlushable = gocbcore.ErrBucketNotFlushable

+ var ErrBucketNotFound = gocbcore.ErrBucketNotFound

+ var ErrCasMismatch = gocbcore.ErrCasMismatch

+ var ErrCollectionExists = gocbcore.ErrCollectionExists

+ var ErrCollectionNotFound = gocbcore.ErrCollectionNotFound

+ var ErrCompilationFailure = gocbcore.ErrCompilationFailure

+ var ErrDatasetExists = gocbcore.ErrDatasetExists

+ var ErrDatasetNotFound = gocbcore.ErrDatasetNotFound

+ var ErrDataverseExists = gocbcore.ErrDataverseExists

+ var ErrDataverseNotFound = gocbcore.ErrDataverseNotFound

+ var ErrDecodingFailure = gocbcore.ErrDecodingFailure

+ var ErrDeltaInvalid = gocbcore.ErrDeltaInvalid

+ var ErrDesignDocumentNotFound = gocbcore.ErrDesignDocumentNotFound

+ var ErrDocumentExists = gocbcore.ErrDocumentExists

+ var ErrDocumentLocked = gocbcore.ErrDocumentLocked

+ var ErrDocumentNotFound = gocbcore.ErrDocumentNotFound

+ var ErrDocumentNotJSON = gocbcore.ErrDocumentNotJSON

+ var ErrDocumentUnretrievable = gocbcore.ErrDocumentUnretrievable

+ var ErrDurabilityAmbiguous = gocbcore.ErrDurabilityAmbiguous

+ var ErrDurabilityImpossible = gocbcore.ErrDurabilityImpossible

+ var ErrDurabilityLevelNotAvailable = gocbcore.ErrDurabilityLevelNotAvailable

+ var ErrDurableWriteInProgress = gocbcore.ErrDurableWriteInProgress

+ var ErrDurableWriteReCommitInProgress = gocbcore.ErrDurableWriteReCommitInProgress

+ var ErrEncodingFailure = gocbcore.ErrEncodingFailure

+ var ErrFeatureNotAvailable = gocbcore.ErrFeatureNotAvailable

+ var ErrGroupNotFound = gocbcore.ErrGroupNotFound

+ var ErrIndexExists = gocbcore.ErrIndexExists

+ var ErrIndexFailure = gocbcore.ErrIndexFailure

+ var ErrIndexNotFound = gocbcore.ErrIndexNotFound

+ var ErrInternalServerFailure = gocbcore.ErrInternalServerFailure

+ var ErrInvalidArgument = gocbcore.ErrInvalidArgument

+ var ErrJobQueueFull = gocbcore.ErrJobQueueFull

+ var ErrLinkNotFound = gocbcore.ErrLinkNotFound

+ var ErrMutationLost = gocbcore.ErrMutationLost

+ var ErrNoResult = errors.New("no result was available")

+ var ErrNumberTooBig = gocbcore.ErrNumberTooBig

+ var ErrOverload = gocbcore.ErrOverload

+ var ErrParsingFailure = gocbcore.ErrParsingFailure

+ var ErrPathExists = gocbcore.ErrPathExists

+ var ErrPathInvalid = gocbcore.ErrPathInvalid

+ var ErrPathMismatch = gocbcore.ErrPathMismatch

+ var ErrPathNotFound = gocbcore.ErrPathNotFound

+ var ErrPathTooBig = gocbcore.ErrPathTooBig

+ var ErrPathTooDeep = gocbcore.ErrPathTooDeep

+ var ErrPlanningFailure = gocbcore.ErrPlanningFailure

+ var ErrPreparedStatementFailure = gocbcore.ErrPreparedStatementFailure

+ var ErrRequestCanceled = gocbcore.ErrRequestCanceled

+ var ErrScopeExists = gocbcore.ErrScopeExists

+ var ErrScopeNotFound = gocbcore.ErrScopeNotFound

+ var ErrServiceNotAvailable = gocbcore.ErrServiceNotAvailable

+ var ErrTemporaryFailure = gocbcore.ErrTemporaryFailure

+ var ErrTimeout = gocbcore.ErrTimeout

+ var ErrUnambiguousTimeout = gocbcore.ErrUnambiguousTimeout

+ var ErrUnsupportedOperation = gocbcore.ErrUnsupportedOperation

+ var ErrUserExists = gocbcore.ErrUserExists

+ var ErrUserNotFound = gocbcore.ErrUserNotFound

+ var ErrValueInvalid = gocbcore.ErrValueInvalid

+ var ErrValueNotJSON = gocbcore.ErrValueNotJSON

+ var ErrValueTooDeep = gocbcore.ErrValueTooDeep

+ var ErrValueTooLarge = gocbcore.ErrValueTooLarge

+ var ErrViewNotFound = gocbcore.ErrViewNotFound

+ var ErrXattrCannotModifyVirtualAttribute = gocbcore.ErrXattrCannotModifyVirtualAttribute

+ var ErrXattrInvalidFlagCombo = gocbcore.ErrXattrInvalidFlagCombo

+ var ErrXattrInvalidKeyCombo = gocbcore.ErrXattrInvalidKeyCombo

+ var ErrXattrInvalidOrder = gocbcore.ErrXattrInvalidOrder

+ var ErrXattrUnknownMacro = gocbcore.ErrXattrUnknownMacro

+ var ErrXattrUnknownVirtualAttribute = gocbcore.ErrXattrUnknownVirtualAttribute

+ var KVCollectionOutdatedRetryReason = RetryReason(gocbcore.KVCollectionOutdatedRetryReason)

+ var KVErrMapRetryReason = RetryReason(gocbcore.KVErrMapRetryReason)

+ var KVLockedRetryReason = RetryReason(gocbcore.KVLockedRetryReason)

+ var KVNotMyVBucketRetryReason = RetryReason(gocbcore.KVNotMyVBucketRetryReason)

+ var KVSyncWriteInProgressRetryReason = RetryReason(gocbcore.KVSyncWriteInProgressRetryReason)

+ var KVSyncWriteRecommitInProgressRetryReason = RetryReason(gocbcore.KVSyncWriteRecommitInProgressRetryReason)

+ var KVTemporaryFailureRetryReason = RetryReason(gocbcore.KVTemporaryFailureRetryReason)

+ var NodeNotAvailableRetryReason = RetryReason(gocbcore.NodeNotAvailableRetryReason)

+ var QueryIndexNotFoundRetryReason = RetryReason(gocbcore.QueryIndexNotFoundRetryReason)

+ var QueryPreparedStatementFailureRetryReason = RetryReason(gocbcore.QueryPreparedStatementFailureRetryReason)

+ var SearchTooManyRequestsRetryReason = RetryReason(gocbcore.SearchTooManyRequestsRetryReason)

+ var ServiceNotAvailableRetryReason = RetryReason(gocbcore.ServiceNotAvailableRetryReason)

+ var ServiceResponseCodeIndicatedRetryReason = RetryReason(gocbcore.ServiceResponseCodeIndicatedRetryReason)

+ var SocketCloseInFlightRetryReason = RetryReason(gocbcore.SocketCloseInFlightRetryReason)

+ var SocketNotAvailableRetryReason = RetryReason(gocbcore.SocketNotAvailableRetryReason)

+ var UnknownRetryReason = RetryReason(gocbcore.UnknownRetryReason)

+ func Identifier() string

+ func SetLogRedactionLevel(level LogRedactLevel)

+ func SetLogger(logger Logger)

+ func Version() string

+ type AllowQueryingSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type AnalyticsDataset struct

+ BucketName string

+ DataverseName string

+ LinkName string

+ Name string

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

+ DatasetName string

+ DataverseName string

+ IsPrimary bool

+ Name string

+ type AnalyticsIndexManager struct

+ func (am *AnalyticsIndexManager) ConnectLink(opts *ConnectAnalyticsLinkOptions) error

+ func (am *AnalyticsIndexManager) CreateDataset(datasetName, bucketName string, opts *CreateAnalyticsDatasetOptions) error

+ func (am *AnalyticsIndexManager) CreateDataverse(dataverseName string, opts *CreateAnalyticsDataverseOptions) error

+ func (am *AnalyticsIndexManager) CreateIndex(datasetName, indexName string, fields map[string]string, ...) error

+ func (am *AnalyticsIndexManager) DisconnectLink(opts *DisconnectAnalyticsLinkOptions) error

+ func (am *AnalyticsIndexManager) DropDataset(datasetName string, opts *DropAnalyticsDatasetOptions) error

+ func (am *AnalyticsIndexManager) DropDataverse(dataverseName string, opts *DropAnalyticsDataverseOptions) error

+ func (am *AnalyticsIndexManager) DropIndex(datasetName, indexName string, opts *DropAnalyticsIndexOptions) error

+ func (am *AnalyticsIndexManager) GetAllDatasets(opts *GetAllAnalyticsDatasetsOptions) ([]AnalyticsDataset, error)

+ func (am *AnalyticsIndexManager) GetAllIndexes(opts *GetAllAnalyticsIndexesOptions) ([]AnalyticsIndex, error)

+ func (am *AnalyticsIndexManager) GetPendingMutations(opts *GetPendingMutationsAnalyticsOptions) (map[string]uint64, error)

+ type AnalyticsMetaData struct

+ ClientContextID string

+ Metrics AnalyticsMetrics

+ RequestID string

+ Signature interface{}

+ Warnings []AnalyticsWarning

+ type AnalyticsMetrics struct

+ ElapsedTime time.Duration

+ ErrorCount uint64

+ ExecutionTime time.Duration

+ MutationCount uint64

+ ProcessedObjects uint64

+ ResultCount uint64

+ ResultSize uint64

+ SortCount uint64

+ WarningCount uint64

+ type AnalyticsOptions struct

+ ClientContextID string

+ NamedParameters map[string]interface{}

+ PositionalParameters []interface{}

+ Priority bool

+ Raw map[string]interface{}

+ Readonly bool

+ RetryStrategy RetryStrategy

+ ScanConsistency AnalyticsScanConsistency

+ Timeout time.Duration

+ type AnalyticsResult struct

+ func (r *AnalyticsResult) Close() error

+ func (r *AnalyticsResult) Err() error

+ func (r *AnalyticsResult) MetaData() (*AnalyticsMetaData, error)

+ func (r *AnalyticsResult) Next() bool

+ func (r *AnalyticsResult) One(valuePtr interface{}) error

+ func (r *AnalyticsResult) Row(valuePtr interface{}) error

+ type AnalyticsScanConsistency uint

+ type AnalyticsWarning struct

+ Code uint32

+ Message string

+ type AnalyzeDocumentOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type AppendOp struct

+ Err error

+ ID string

+ Result *MutationResult

+ Value string

+ type AppendOptions struct

+ Cas Cas

+ DurabilityLevel DurabilityLevel

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type ArrayAddUniqueSpecOptions struct

+ CreatePath bool

+ IsXattr bool

+ type ArrayAppendSpecOptions struct

+ CreatePath bool

+ HasMultiple bool

+ IsXattr bool

+ type ArrayInsertSpecOptions struct

+ CreatePath bool

+ HasMultiple bool

+ IsXattr bool

+ type ArrayPrependSpecOptions struct

+ CreatePath bool

+ HasMultiple bool

+ IsXattr bool

+ type AuthCertRequest struct

+ Endpoint string

+ Service ServiceType

+ type AuthCredsRequest struct

+ Endpoint string

+ Service ServiceType

+ type AuthDomain string

+ const ExternalDomain

+ const LocalDomain

+ type Authenticator 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

+ type BestEffortRetryStrategy struct

+ BackoffCalculator BackoffCalculator

+ func NewBestEffortRetryStrategy(calculator BackoffCalculator) *BestEffortRetryStrategy

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

+ type BinaryCollection struct

+ func (c *BinaryCollection) Append(id string, val []byte, opts *AppendOptions) (mutOut *MutationResult, errOut error)

+ func (c *BinaryCollection) Decrement(id string, opts *DecrementOptions) (countOut *CounterResult, errOut error)

+ func (c *BinaryCollection) Increment(id string, opts *IncrementOptions) (countOut *CounterResult, errOut error)

+ func (c *BinaryCollection) Prepend(id string, val []byte, opts *PrependOptions) (mutOut *MutationResult, errOut error)

+ type Bucket struct

+ func (b *Bucket) Collection(collectionName string) *Collection

+ func (b *Bucket) Collections() *CollectionManager

+ func (b *Bucket) DefaultCollection() *Collection

+ func (b *Bucket) DefaultScope() *Scope

+ func (b *Bucket) Name() string

+ func (b *Bucket) Ping(opts *PingOptions) (*PingResult, error)

+ func (b *Bucket) Scope(scopeName string) *Scope

+ func (b *Bucket) ViewIndexes() *ViewIndexManager

+ func (b *Bucket) ViewQuery(designDoc string, viewName string, opts *ViewOptions) (*ViewResult, error)

+ type BucketManager struct

+ func (bm *BucketManager) CreateBucket(settings CreateBucketSettings, opts *CreateBucketOptions) error

+ func (bm *BucketManager) DropBucket(name string, opts *DropBucketOptions) error

+ func (bm *BucketManager) FlushBucket(name string, opts *FlushBucketOptions) error

+ func (bm *BucketManager) GetAllBuckets(opts *GetAllBucketsOptions) (map[string]BucketSettings, error)

+ func (bm *BucketManager) GetBucket(bucketName string, opts *GetBucketOptions) (*BucketSettings, error)

+ func (bm *BucketManager) UpdateBucket(settings BucketSettings, opts *UpdateBucketOptions) error

+ type BucketSettings struct

+ BucketType BucketType

+ CompressionMode CompressionMode

+ EvictionPolicy EvictionPolicyType

+ FlushEnabled bool

+ MaxTTL time.Duration

+ Name string

+ NumReplicas uint32

+ RAMQuotaMB uint64

+ ReplicaIndexDisabled bool

+ type BucketType string

+ type BuildDeferredQueryIndexOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type BulkOp interface

+ type BulkOpOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type Cas gocbcore.Cas

+ type CertificateAuthenticator struct

+ ClientCertificate *tls.Certificate

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

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

+ func (ca CertificateAuthenticator) SupportsNonTLS() bool

+ func (ca CertificateAuthenticator) SupportsTLS() bool

+ type CircuitBreakerCallback func(error) bool

+ type CircuitBreakerConfig struct

+ CanaryTimeout time.Duration

+ CompletionCallback CircuitBreakerCallback

+ Disabled bool

+ ErrorThresholdPercentage float64

+ RollingWindow time.Duration

+ SleepWindow time.Duration

+ VolumeThreshold int64

+ type Cluster struct

+ func Connect(connStr string, opts ClusterOptions) (*Cluster, error)

+ func (c *Cluster) AnalyticsIndexes() *AnalyticsIndexManager

+ func (c *Cluster) AnalyticsQuery(statement string, opts *AnalyticsOptions) (*AnalyticsResult, error)

+ func (c *Cluster) Bucket(bucketName string) *Bucket

+ func (c *Cluster) Buckets() *BucketManager

+ func (c *Cluster) Close(opts *ClusterCloseOptions) error

+ func (c *Cluster) Diagnostics(opts *DiagnosticsOptions) (*DiagnosticsResult, error)

+ func (c *Cluster) Query(statement string, opts *QueryOptions) (*QueryResult, error)

+ func (c *Cluster) QueryIndexes() *QueryIndexManager

+ func (c *Cluster) SearchIndexes() *SearchIndexManager

+ func (c *Cluster) SearchQuery(indexName string, query cbsearch.Query, opts *SearchOptions) (*SearchResult, error)

+ func (c *Cluster) Users() *UserManager

+ type ClusterCloseOptions struct

+ type ClusterOptions struct

+ Authenticator Authenticator

+ CircuitBreakerConfig CircuitBreakerConfig

+ IoConfig IoConfig

+ OrphanReporterConfig OrphanReporterConfig

+ Password string

+ RetryStrategy RetryStrategy

+ SecurityConfig SecurityConfig

+ TimeoutsConfig TimeoutsConfig

+ Tracer requestTracer

+ Transcoder Transcoder

+ Username string

+ type ClusterState uint

+ type Collection struct

+ func (c *Collection) Binary() *BinaryCollection

+ func (c *Collection) Do(ops []BulkOp, opts *BulkOpOptions) error

+ func (c *Collection) Exists(id string, opts *ExistsOptions) (docOut *ExistsResult, errOut error)

+ func (c *Collection) Get(id string, opts *GetOptions) (docOut *GetResult, errOut error)

+ func (c *Collection) GetAllReplicas(id string, opts *GetAllReplicaOptions) (docOut *GetAllReplicasResult, errOut error)

+ func (c *Collection) GetAndLock(id string, lockTime time.Duration, opts *GetAndLockOptions) (docOut *GetResult, errOut error)

+ func (c *Collection) GetAndTouch(id string, expiry time.Duration, opts *GetAndTouchOptions) (docOut *GetResult, errOut error)

+ func (c *Collection) GetAnyReplica(id string, opts *GetAnyReplicaOptions) (docOut *GetReplicaResult, errOut error)

+ func (c *Collection) Insert(id string, val interface{}, opts *InsertOptions) (mutOut *MutationResult, errOut error)

+ func (c *Collection) List(id string) *CouchbaseList

+ func (c *Collection) LookupIn(id string, ops []LookupInSpec, opts *LookupInOptions) (docOut *LookupInResult, errOut error)

+ func (c *Collection) Map(id string) *CouchbaseMap

+ func (c *Collection) MutateIn(id string, ops []MutateInSpec, opts *MutateInOptions) (mutOut *MutateInResult, errOut error)

+ func (c *Collection) Name() string

+ func (c *Collection) Queue(id string) *CouchbaseQueue

+ func (c *Collection) Remove(id string, opts *RemoveOptions) (mutOut *MutationResult, errOut error)

+ func (c *Collection) Replace(id string, val interface{}, opts *ReplaceOptions) (mutOut *MutationResult, errOut error)

+ func (c *Collection) Set(id string) *CouchbaseSet

+ func (c *Collection) Touch(id string, expiry time.Duration, opts *TouchOptions) (mutOut *MutationResult, errOut error)

+ func (c *Collection) Unlock(id string, cas Cas, opts *UnlockOptions) (errOut error)

+ func (c *Collection) Upsert(id string, val interface{}, opts *UpsertOptions) (mutOut *MutationResult, errOut error)

+ type CollectionManager struct

+ func (cm *CollectionManager) CreateCollection(spec CollectionSpec, opts *CreateCollectionOptions) error

+ func (cm *CollectionManager) CreateScope(scopeName string, opts *CreateScopeOptions) error

+ func (cm *CollectionManager) DropCollection(spec CollectionSpec, opts *DropCollectionOptions) error

+ func (cm *CollectionManager) DropScope(scopeName string, opts *DropScopeOptions) error

+ func (cm *CollectionManager) GetAllScopes(opts *GetAllScopesOptions) ([]ScopeSpec, error)

+ type CollectionSpec struct

+ Name string

+ ScopeName string

+ type CompressionMode string

+ type ConflictResolutionType string

+ type ConnectAnalyticsLinkOptions struct

+ LinkName string

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CouchbaseList struct

+ func (cl *CouchbaseList) Append(val interface{}) error

+ func (cl *CouchbaseList) At(index int, valuePtr interface{}) error

+ func (cl *CouchbaseList) Clear() error

+ func (cl *CouchbaseList) IndexOf(val interface{}) (int, error)

+ func (cl *CouchbaseList) Iterator() ([]interface{}, error)

+ func (cl *CouchbaseList) Prepend(val interface{}) error

+ func (cl *CouchbaseList) RemoveAt(index int) error

+ func (cl *CouchbaseList) Size() (int, error)

+ type CouchbaseMap struct

+ func (cl *CouchbaseMap) Add(id string, val interface{}) error

+ func (cl *CouchbaseMap) At(id string, valuePtr interface{}) error

+ func (cl *CouchbaseMap) Clear() error

+ func (cl *CouchbaseMap) Exists(id string) (bool, error)

+ func (cl *CouchbaseMap) Iterator() (map[string]interface{}, error)

+ func (cl *CouchbaseMap) Keys() ([]string, error)

+ func (cl *CouchbaseMap) Remove(id string) error

+ func (cl *CouchbaseMap) Size() (int, error)

+ func (cl *CouchbaseMap) Values() ([]interface{}, error)

+ type CouchbaseQueue struct

+ func (cs *CouchbaseQueue) Clear() error

+ func (cs *CouchbaseQueue) Iterator() ([]interface{}, error)

+ func (cs *CouchbaseQueue) Pop(valuePtr interface{}) error

+ func (cs *CouchbaseQueue) Push(val interface{}) error

+ func (cs *CouchbaseQueue) Size() (int, error)

+ type CouchbaseSet struct

+ func (cs *CouchbaseSet) Add(val interface{}) error

+ func (cs *CouchbaseSet) Clear() error

+ func (cs *CouchbaseSet) Contains(val string) (bool, error)

+ func (cs *CouchbaseSet) Iterator() ([]interface{}, error)

+ func (cs *CouchbaseSet) Remove(val string) error

+ func (cs *CouchbaseSet) Size() (int, error)

+ func (cs *CouchbaseSet) Values() ([]interface{}, error)

+ type CountSpecOptions struct

+ IsXattr bool

+ type CounterResult struct

+ func (mr CounterResult) Cas() Cas

+ func (mr CounterResult) Content() uint64

+ func (mr CounterResult) MutationToken() *MutationToken

+ type CounterSpecOptions struct

+ CreatePath bool

+ IsXattr bool

+ type CreateAnalyticsDatasetOptions struct

+ Condition string

+ DataverseName string

+ IgnoreIfExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CreateAnalyticsDataverseOptions struct

+ IgnoreIfExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CreateAnalyticsIndexOptions struct

+ DataverseName string

+ IgnoreIfExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CreateBucketOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CreateBucketSettings struct

+ ConflictResolutionType ConflictResolutionType

+ type CreateCollectionOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CreatePrimaryQueryIndexOptions struct

+ CustomName string

+ Deferred bool

+ IgnoreIfExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CreateQueryIndexOptions struct

+ Deferred bool

+ IgnoreIfExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type CreateScopeOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DecrementOp struct

+ Delta int64

+ Err error

+ Expiry time.Duration

+ ID string

+ Initial int64

+ Result *CounterResult

+ type DecrementOptions struct

+ Cas Cas

+ Delta uint64

+ DurabilityLevel DurabilityLevel

+ Expiry time.Duration

+ Initial int64

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DesignDocument struct

+ Name string

+ Views map[string]View

+ type DesignDocumentNamespace uint

+ type DiagnosticsOptions struct

+ ReportID string

+ type DiagnosticsResult struct

+ ID string

+ Services map[string][]EndPointDiagnostics

+ func (report *DiagnosticsResult) MarshalJSON() ([]byte, error)

+ type DisallowQueryingSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DisconnectAnalyticsLinkOptions struct

+ LinkName string

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropAnalyticsDatasetOptions struct

+ DataverseName string

+ IgnoreIfNotExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropAnalyticsDataverseOptions struct

+ IgnoreIfNotExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropAnalyticsIndexOptions struct

+ DataverseName string

+ IgnoreIfNotExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropBucketOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropCollectionOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropDesignDocumentOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropGroupOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropPrimaryQueryIndexOptions struct

+ CustomName string

+ IgnoreIfNotExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropQueryIndexOptions struct

+ IgnoreIfNotExists bool

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropScopeOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DropUserOptions struct

+ DomainName string

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type DurabilityLevel uint8

+ type EndPointDiagnostics struct

+ ID string

+ LastActivity time.Time

+ Local string

+ Namespace string

+ Remote string

+ State EndpointState

+ Type ServiceType

+ type EndpointPingReport struct

+ Error string

+ ID string

+ Latency time.Duration

+ Local string

+ Namespace string

+ Remote string

+ State PingState

+ type EndpointState uint

+ type EvictionPolicyType string

+ type ExistsOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type ExistsResult struct

+ func (d *ExistsResult) Exists() bool

+ type ExistsSpecOptions struct

+ IsXattr bool

+ type FlushBucketOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type FreezePlanSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllAnalyticsDatasetsOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllAnalyticsIndexesOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllBucketsOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllDesignDocumentsOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllGroupsOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllQueryIndexesOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllReplicaOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type GetAllReplicasResult struct

+ func (r *GetAllReplicasResult) Close() error

+ func (r *GetAllReplicasResult) Next() *GetReplicaResult

+ type GetAllScopesOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAllUsersOptions struct

+ DomainName string

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetAndLockOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type GetAndTouchOp struct

+ Err error

+ Expiry time.Duration

+ ID string

+ Result *GetResult

+ type GetAndTouchOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type GetAnyReplicaOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type GetBucketOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetDesignDocumentOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetGroupOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetIndexedDocumentsCountOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetOp struct

+ Err error

+ ID string

+ Result *GetResult

+ type GetOptions struct

+ Project []string

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ WithExpiry bool

+ type GetPendingMutationsAnalyticsOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetReplicaResult struct

+ func (r *GetReplicaResult) IsReplica() bool

+ type GetResult struct

+ func (d *GetResult) Content(valuePtr interface{}) error

+ func (d *GetResult) Expiry() *time.Duration

+ type GetRolesOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type GetSpecOptions struct

+ IsXattr bool

+ type GetUserOptions struct

+ DomainName string

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type Group struct

+ Description string

+ LDAPGroupReference string

+ Name string

+ Roles []Role

+ type HTTPError struct

+ Endpoint string

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ UniqueID string

+ func (e HTTPError) Error() string

+ func (e HTTPError) Unwrap() error

+ type IncrementOp struct

+ Delta int64

+ Err error

+ Expiry time.Duration

+ ID string

+ Initial int64

+ Result *CounterResult

+ type IncrementOptions struct

+ Cas Cas

+ Delta uint64

+ DurabilityLevel DurabilityLevel

+ Expiry time.Duration

+ Initial int64

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type InsertOp struct

+ Err error

+ Expiry time.Duration

+ ID string

+ Result *MutationResult

+ Value interface{}

+ type InsertOptions struct

+ DurabilityLevel DurabilityLevel

+ Expiry time.Duration

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type InsertSpecOptions struct

+ CreatePath bool

+ IsXattr bool

+ type IoConfig struct

+ DisableMutationTokens bool

+ DisableServerDurations bool

+ type JSONTranscoder struct

+ func NewJSONTranscoder() *JSONTranscoder

+ func (t *JSONTranscoder) Decode(bytes []byte, flags uint32, out interface{}) error

+ func (t *JSONTranscoder) Encode(value interface{}) ([]byte, uint32, error)

+ 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 gocbcore.StatusCode

+ func (e KeyValueError) Error() string

+ func (e KeyValueError) Unwrap() error

+ type LegacyTranscoder struct

+ func NewLegacyTranscoder() *LegacyTranscoder

+ func (t *LegacyTranscoder) Decode(bytes []byte, flags uint32, out interface{}) error

+ func (t *LegacyTranscoder) Encode(value interface{}) ([]byte, uint32, error)

+ type LogLevel gocbcore.LogLevel

+ type LogRedactLevel uint

+ type Logger interface

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

+ func DefaultStdioLogger() Logger

+ func VerboseStdioLogger() Logger

+ type LookupInOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type LookupInResult struct

+ func (lir *LookupInResult) ContentAt(idx uint, valuePtr interface{}) error

+ func (lir *LookupInResult) Exists(idx uint) bool

+ type LookupInSpec struct

+ func CountSpec(path string, opts *CountSpecOptions) LookupInSpec

+ func ExistsSpec(path string, opts *ExistsSpecOptions) LookupInSpec

+ func GetSpec(path string, opts *GetSpecOptions) LookupInSpec

+ type MutateInOptions struct

+ Cas Cas

+ DurabilityLevel DurabilityLevel

+ Expiry time.Duration

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ StoreSemantic StoreSemantics

+ Timeout time.Duration

+ type MutateInResult struct

+ func (mir MutateInResult) ContentAt(idx uint, valuePtr interface{}) error

+ type MutateInSpec struct

+ func ArrayAddUniqueSpec(path string, val interface{}, opts *ArrayAddUniqueSpecOptions) MutateInSpec

+ func ArrayAppendSpec(path string, val interface{}, opts *ArrayAppendSpecOptions) MutateInSpec

+ func ArrayInsertSpec(path string, val interface{}, opts *ArrayInsertSpecOptions) MutateInSpec

+ func ArrayPrependSpec(path string, val interface{}, opts *ArrayPrependSpecOptions) MutateInSpec

+ func DecrementSpec(path string, delta int64, opts *CounterSpecOptions) MutateInSpec

+ func IncrementSpec(path string, delta int64, opts *CounterSpecOptions) MutateInSpec

+ func InsertSpec(path string, val interface{}, opts *InsertSpecOptions) MutateInSpec

+ func RemoveSpec(path string, opts *RemoveSpecOptions) MutateInSpec

+ func ReplaceSpec(path string, val interface{}, opts *ReplaceSpecOptions) MutateInSpec

+ func UpsertSpec(path string, val interface{}, opts *UpsertSpecOptions) MutateInSpec

+ type MutationMacro string

+ type MutationResult struct

+ func (mr MutationResult) MutationToken() *MutationToken

+ type MutationState struct

+ func NewMutationState(tokens ...MutationToken) *MutationState

+ func (mt *MutationState) Add(tokens ...MutationToken)

+ func (mt *MutationState) MarshalJSON() ([]byte, error)

+ func (mt *MutationState) UnmarshalJSON(data []byte) error

+ type MutationToken struct

+ func (mt MutationToken) BucketName() string

+ func (mt MutationToken) PartitionID() uint64

+ func (mt MutationToken) PartitionUUID() uint64

+ func (mt MutationToken) SequenceNumber() uint64

+ type NoRetryRetryAction struct

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

+ type Origin struct

+ Name string

+ Type string

+ type OrphanReporterConfig struct

+ Disabled bool

+ ReportInterval time.Duration

+ SampleSize uint32

+ type PasswordAuthenticator struct

+ Password string

+ Username string

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

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

+ func (ra PasswordAuthenticator) SupportsNonTLS() bool

+ func (ra PasswordAuthenticator) SupportsTLS() bool

+ type PauseIngestSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type PingOptions struct

+ ReportID string

+ ServiceTypes []ServiceType

+ type PingResult struct

+ ID string

+ Services map[ServiceType][]EndpointPingReport

+ func (report *PingResult) MarshalJSON() ([]byte, error)

+ type PingState uint

+ type PrependOp struct

+ Err error

+ ID string

+ Result *MutationResult

+ Value string

+ type PrependOptions struct

+ Cas Cas

+ DurabilityLevel DurabilityLevel

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type PublishDesignDocumentOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type QueryError struct

+ ClientContextID string

+ Endpoint string

+ Errors []QueryErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ Statement string

+ func (e QueryError) Error() string

+ func (e QueryError) Unwrap() error

+ type QueryErrorDesc struct

+ Code uint32

+ Message string

+ type QueryIndex struct

+ Condition string

+ IndexKey []string

+ IsPrimary bool

+ Keyspace string

+ Name string

+ Namespace string

+ State string

+ Type QueryIndexType

+ type QueryIndexManager struct

+ func (qm *QueryIndexManager) BuildDeferredIndexes(bucketName string, opts *BuildDeferredQueryIndexOptions) ([]string, error)

+ func (qm *QueryIndexManager) CreateIndex(bucketName, indexName string, fields []string, opts *CreateQueryIndexOptions) error

+ func (qm *QueryIndexManager) CreatePrimaryIndex(bucketName string, opts *CreatePrimaryQueryIndexOptions) error

+ func (qm *QueryIndexManager) DropIndex(bucketName, indexName string, opts *DropQueryIndexOptions) error

+ func (qm *QueryIndexManager) DropPrimaryIndex(bucketName string, opts *DropPrimaryQueryIndexOptions) error

+ func (qm *QueryIndexManager) GetAllIndexes(bucketName string, opts *GetAllQueryIndexesOptions) ([]QueryIndex, error)

+ func (qm *QueryIndexManager) WatchIndexes(bucketName string, watchList []string, timeout time.Duration, ...) error

+ type QueryIndexType string

+ type QueryMetaData struct

+ ClientContextID string

+ Metrics QueryMetrics

+ Profile interface{}

+ RequestID string

+ Signature interface{}

+ Status QueryStatus

+ Warnings []QueryWarning

+ type QueryMetrics struct

+ ElapsedTime time.Duration

+ ErrorCount uint64

+ ExecutionTime time.Duration

+ MutationCount uint64

+ ResultCount uint64

+ ResultSize uint64

+ SortCount uint64

+ WarningCount uint64

+ type QueryOptions struct

+ Adhoc bool

+ ClientContextID string

+ ConsistentWith *MutationState

+ MaxParallelism uint32

+ Metrics bool

+ NamedParameters map[string]interface{}

+ PipelineBatch uint32

+ PipelineCap uint32

+ PositionalParameters []interface{}

+ Profile QueryProfileMode

+ Raw map[string]interface{}

+ Readonly bool

+ RetryStrategy RetryStrategy

+ ScanCap uint32

+ ScanConsistency QueryScanConsistency

+ ScanWait time.Duration

+ Timeout time.Duration

+ type QueryProfileMode string

+ type QueryResult struct

+ func (r *QueryResult) Close() error

+ func (r *QueryResult) Err() error

+ func (r *QueryResult) MetaData() (*QueryMetaData, error)

+ func (r *QueryResult) Next() bool

+ func (r *QueryResult) One(valuePtr interface{}) error

+ func (r *QueryResult) Row(valuePtr interface{}) error

+ type QueryScanConsistency uint

+ type QueryStatus string

+ type QueryWarning struct

+ Code uint32

+ Message string

+ type RawBinaryTranscoder struct

+ func NewRawBinaryTranscoder() *RawBinaryTranscoder

+ func (t *RawBinaryTranscoder) Decode(bytes []byte, flags uint32, out interface{}) error

+ func (t *RawBinaryTranscoder) Encode(value interface{}) ([]byte, uint32, error)

+ type RawJSONTranscoder struct

+ func NewRawJSONTranscoder() *RawJSONTranscoder

+ func (t *RawJSONTranscoder) Decode(bytes []byte, flags uint32, out interface{}) error

+ func (t *RawJSONTranscoder) Encode(value interface{}) ([]byte, uint32, error)

+ type RawStringTranscoder struct

+ func NewRawStringTranscoder() *RawStringTranscoder

+ func (t *RawStringTranscoder) Decode(bytes []byte, flags uint32, out interface{}) error

+ func (t *RawStringTranscoder) Encode(value interface{}) ([]byte, uint32, error)

+ type RemoveOp struct

+ Cas Cas

+ Err error

+ ID string

+ Result *MutationResult

+ type RemoveOptions struct

+ Cas Cas

+ DurabilityLevel DurabilityLevel

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type RemoveSpecOptions struct

+ IsXattr bool

+ type ReplaceOp struct

+ Cas Cas

+ Err error

+ Expiry time.Duration

+ ID string

+ Result *MutationResult

+ Value interface{}

+ type ReplaceOptions struct

+ Cas Cas

+ DurabilityLevel DurabilityLevel

+ Expiry time.Duration

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type ReplaceSpecOptions struct

+ IsXattr bool

+ type Result struct

+ func (d *Result) Cas() Cas

+ type ResumeIngestSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

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

+ Bucket string

+ Name string

+ type RoleAndDescription struct

+ Description string

+ DisplayName string

+ type RoleAndOrigins struct

+ Origins []Origin

+ type Scope struct

+ func (s *Scope) Collection(collectionName string) *Collection

+ func (s *Scope) Name() string

+ type ScopeSpec struct

+ Collections []CollectionSpec

+ Name string

+ type SearchError struct

+ Endpoint string

+ InnerError error

+ Query interface{}

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ func (e SearchError) Error() string

+ func (e SearchError) Unwrap() error

+ type SearchFacetResult struct

+ Field string

+ Missing uint64

+ Name string

+ Other uint64

+ Total uint64

+ type SearchHighlightOptions struct

+ Fields []string

+ Style SearchHighlightStyle

+ type SearchHighlightStyle string

+ type SearchIndex struct

+ Name string

+ Params map[string]interface{}

+ PlanParams map[string]interface{}

+ SourceName string

+ SourceParams map[string]interface{}

+ SourceType string

+ SourceUUID string

+ Type string

+ UUID string

+ type SearchIndexManager struct

+ func (sm *SearchIndexManager) AllowQuerying(indexName string, opts *AllowQueryingSearchIndexOptions) error

+ func (sm *SearchIndexManager) AnalyzeDocument(indexName string, doc interface{}, opts *AnalyzeDocumentOptions) ([]interface{}, error)

+ func (sm *SearchIndexManager) DisallowQuerying(indexName string, opts *AllowQueryingSearchIndexOptions) error

+ func (sm *SearchIndexManager) DropIndex(indexName string, opts *DropSearchIndexOptions) error

+ func (sm *SearchIndexManager) FreezePlan(indexName string, opts *AllowQueryingSearchIndexOptions) error

+ func (sm *SearchIndexManager) GetAllIndexes(opts *GetAllSearchIndexOptions) ([]SearchIndex, error)

+ func (sm *SearchIndexManager) GetIndex(indexName string, opts *GetSearchIndexOptions) (*SearchIndex, error)

+ func (sm *SearchIndexManager) GetIndexedDocumentsCount(indexName string, opts *GetIndexedDocumentsCountOptions) (uint64, error)

+ func (sm *SearchIndexManager) PauseIngest(indexName string, opts *PauseIngestSearchIndexOptions) error

+ func (sm *SearchIndexManager) ResumeIngest(indexName string, opts *ResumeIngestSearchIndexOptions) error

+ func (sm *SearchIndexManager) UnfreezePlan(indexName string, opts *AllowQueryingSearchIndexOptions) error

+ func (sm *SearchIndexManager) UpsertIndex(indexDefinition SearchIndex, opts *UpsertSearchIndexOptions) error

+ type SearchMetaData struct

+ Errors map[string]string

+ Metrics SearchMetrics

+ type SearchMetrics struct

+ ErrorPartitionCount uint64

+ MaxScore float64

+ SuccessPartitionCount uint64

+ Took time.Duration

+ TotalPartitionCount uint64

+ TotalRows uint64

+ type SearchOptions struct

+ ConsistentWith *MutationState

+ Explain bool

+ Facets map[string]cbsearch.Facet

+ Fields []string

+ Highlight *SearchHighlightOptions

+ Limit uint32

+ Raw map[string]interface{}

+ RetryStrategy RetryStrategy

+ ScanConsistency SearchScanConsistency

+ Skip uint32

+ Sort []cbsearch.Sort

+ Timeout time.Duration

+ type SearchResult struct

+ func (r *SearchResult) Close() error

+ func (r *SearchResult) Err() error

+ func (r *SearchResult) Facets() (map[string]SearchFacetResult, error)

+ func (r *SearchResult) MetaData() (*SearchMetaData, error)

+ func (r *SearchResult) Next() bool

+ func (r *SearchResult) Row() SearchRow

+ type SearchRow struct

+ Explanation interface{}

+ Fragments map[string][]string

+ ID string

+ Index string

+ Locations map[string]map[string][]SearchRowLocation

+ Score float64

+ func (sr *SearchRow) Fields(valuePtr interface{}) error

+ type SearchRowLocation struct

+ ArrayPositions []uint32

+ End uint32

+ Position uint32

+ Start uint32

+ type SearchScanConsistency uint

+ type SecurityConfig struct

+ TLSRootCAs *x509.CertPool

+ TLSSkipVerify bool

+ type ServiceType gocbcore.ServiceType

+ type StoreSemantics uint8

+ type SubdocDocFlag gocbcore.SubdocDocFlag

+ type SubdocFlag gocbcore.SubdocFlag

+ type ThresholdLoggingOptions struct

+ AnalyticsThreshold time.Duration

+ Interval time.Duration

+ KVThreshold time.Duration

+ ManagementThreshold time.Duration

+ QueryThreshold time.Duration

+ SampleSize uint32

+ SearchThreshold time.Duration

+ ServerDurationDisabled bool

+ ViewsThreshold time.Duration

+ type TimeoutsConfig struct

+ AnalyticsTimeout time.Duration

+ ConnectTimeout time.Duration

+ KVTimeout time.Duration

+ ManagementTimeout time.Duration

+ QueryTimeout time.Duration

+ SearchTimeout time.Duration

+ ViewTimeout time.Duration

+ type TouchOp struct

+ Err error

+ Expiry time.Duration

+ ID string

+ Result *MutationResult

+ type TouchOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type Transcoder interface

+ Decode func([]byte, uint32, interface{}) error

+ Encode func(interface{}) ([]byte, uint32, error)

+ type UnfreezePlanSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type UnlockOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type UpdateBucketOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type UpsertDesignDocumentOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type UpsertGroupOptions struct

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type UpsertOp struct

+ Cas Cas

+ Err error

+ Expiry time.Duration

+ ID string

+ Result *MutationResult

+ Value interface{}

+ type UpsertOptions struct

+ DurabilityLevel DurabilityLevel

+ Expiry time.Duration

+ PersistTo uint

+ ReplicateTo uint

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ Transcoder Transcoder

+ type UpsertSearchIndexOptions struct

+ Context context.Context

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type UpsertSpecOptions struct

+ CreatePath bool

+ IsXattr bool

+ type UpsertUserOptions struct

+ DomainName string

+ RetryStrategy RetryStrategy

+ Timeout time.Duration

+ type User struct

+ DisplayName string

+ Groups []string

+ Password string

+ Roles []Role

+ Username string

+ type UserAndMetadata struct

+ Domain AuthDomain

+ EffectiveRoles []RoleAndOrigins

+ ExternalGroups []string

+ PasswordChanged time.Time

+ type UserManager struct

+ func (um *UserManager) DropGroup(groupName string, opts *DropGroupOptions) error

+ func (um *UserManager) DropUser(name string, opts *DropUserOptions) error

+ func (um *UserManager) GetAllGroups(opts *GetAllGroupsOptions) ([]Group, error)

+ func (um *UserManager) GetAllUsers(opts *GetAllUsersOptions) ([]UserAndMetadata, error)

+ func (um *UserManager) GetGroup(groupName string, opts *GetGroupOptions) (*Group, error)

+ func (um *UserManager) GetRoles(opts *GetRolesOptions) ([]RoleAndDescription, error)

+ func (um *UserManager) GetUser(name string, opts *GetUserOptions) (*UserAndMetadata, error)

+ func (um *UserManager) UpsertGroup(group Group, opts *UpsertGroupOptions) error

+ func (um *UserManager) UpsertUser(user User, opts *UpsertUserOptions) error

+ type UserPassPair gocbcore.UserPassPair

+ type View struct

+ Map string

+ Reduce string

+ type ViewError struct

+ DesignDocumentName string

+ Endpoint string

+ Errors []ViewErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ ViewName string

+ func (e ViewError) Error() string

+ func (e ViewError) Unwrap() error

+ type ViewErrorDesc struct

+ Message string

+ SourceNode string

+ type ViewErrorMode uint

+ type ViewIndexManager struct

+ func (vm *ViewIndexManager) DropDesignDocument(name string, namespace DesignDocumentNamespace, ...) error

+ func (vm *ViewIndexManager) GetAllDesignDocuments(namespace DesignDocumentNamespace, opts *GetAllDesignDocumentsOptions) ([]DesignDocument, error)

+ func (vm *ViewIndexManager) GetDesignDocument(name string, namespace DesignDocumentNamespace, opts *GetDesignDocumentOptions) (*DesignDocument, error)

+ func (vm *ViewIndexManager) PublishDesignDocument(name string, opts *PublishDesignDocumentOptions) error

+ func (vm *ViewIndexManager) UpsertDesignDocument(ddoc DesignDocument, namespace DesignDocumentNamespace, ...) error

+ type ViewMetaData struct

+ Debug interface{}

+ TotalRows uint64

+ type ViewOptions struct

+ Debug bool

+ EndKey interface{}

+ EndKeyDocID string

+ Group bool

+ GroupLevel uint32

+ InclusiveEnd bool

+ Key interface{}

+ Keys []interface{}

+ Limit uint32

+ Namespace DesignDocumentNamespace

+ OnError ViewErrorMode

+ Order ViewOrdering

+ Raw map[string]string

+ Reduce bool

+ RetryStrategy RetryStrategy

+ ScanConsistency ViewScanConsistency

+ Skip uint32

+ StartKey interface{}

+ StartKeyDocID string

+ Timeout time.Duration

+ type ViewOrdering uint

+ type ViewResult struct

+ func (r *ViewResult) Close() error

+ func (r *ViewResult) Err() error

+ func (r *ViewResult) MetaData() (*ViewMetaData, error)

+ func (r *ViewResult) Next() bool

+ func (r *ViewResult) Row() ViewRow

+ type ViewRow struct

+ ID string

+ func (vr *ViewRow) Key(valuePtr interface{}) error

+ func (vr *ViewRow) Value(valuePtr interface{}) error

+ type ViewScanConsistency uint

+ type WatchQueryIndexOptions struct

+ RetryStrategy RetryStrategy

+ WatchPrimary bool

+ type WithDurationRetryAction struct

+ WithDuration time.Duration

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

v2.0.0-beta.1

Oct 3, 2019

v2.0.0-alpha.5

Aug 8, 2019

v2.0.0-alpha.4

Jul 25, 2019

v2.0.0-alpha.3

May 14, 2019

v2.0.0-alpha.2

Apr 16, 2019

v2.0.0-alpha.1

Mar 26, 2019

Other modules containing this package

github.com/couchbase/gocb

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