gocbcore

package module

Go to main page

Versions in this module

v9

v9.1.10

May 3, 2023

v9.1.9

Apr 20, 2023

Changes in this version

+ type DCPRollbackError struct

+ InnerError error

+ SeqNo SeqNo

+ func (err DCPRollbackError) Error() string

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

+ func (err DCPRollbackError) Unwrap() error

v9.1.8

Jan 18, 2022

Changes in this version

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

+ var ErrMemdDCPStreamIDInvalid = makeKvStatusError(memd.StatusDCPStreamIDInvalid)

v9.1.7

Sep 21, 2021

Changes in this version

type AgentConfig

+ InitialBootstrapNonTLS bool

type DCPAgentConfig

+ InitialBootstrapNonTLS bool

v9.1.6

Aug 18, 2021

Changes in this version

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

type Agent

+ func (agent *Agent) ForceReconnect()

type DCPAgent

+ func (agent *DCPAgent) ForceReconnect()

v9.1.5

Jun 15, 2021

v9.1.4

Apr 20, 2021

Changes in this version

type AgentConfig

+ HTTPMaxWait time.Duration

type DCPAgentConfig

+ HTTPMaxWait time.Duration

v9.1.3

Mar 16, 2021

Changes in this version

type AgentInternal

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

type DCPAgentConfig

+ DisableBufferAcknowledgement bool

type RequestSpan

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

+ End func()

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

type RequestTracer

+ RequestSpan func(parentContext RequestSpanContext, operationName string) RequestSpan

v9.1.2

Feb 16, 2021

Changes in this version

type ManifestCollection

+ MaxTTL uint32

v9.1.1

Jan 20, 2021

Changes in this version

type Agent

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

+ type AgentInternal struct

+ func (ai *AgentInternal) HasBucketCapabilityStatus(cap BucketCapability, status BucketCapabilityStatus) bool

type AnalyticsError

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

+ type BucketCapability uint32

+ const BucketCapabilityCreateAsDeleted

+ const BucketCapabilityDurableWrites

+ const BucketCapabilityReplaceBodyWithXattr

+ type BucketCapabilityStatus uint32

+ const BucketCapabilityStatusSupported

+ const BucketCapabilityStatusUnknown

+ const BucketCapabilityStatusUnsupported

type HTTPError

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

type KeyValueError

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

type N1QLError

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

type SearchError

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

type ViewError

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

v9.1.0

Dec 15, 2020

Changes in this version

type AddOptions

+ User []byte

type AdjoinOptions

+ User []byte

type CounterOptions

+ User []byte

type DeleteMetaOptions

+ User []byte

type DeleteOptions

+ User []byte

type GetAndLockOptions

+ User []byte

type GetAndTouchOptions

+ User []byte

type GetAnyReplicaOptions

+ User []byte

type GetMetaOptions

+ User []byte

type GetOneReplicaOptions

+ User []byte

type GetOptions

+ User []byte

type GetRandomOptions

+ User []byte

type LookupInOptions

+ User []byte

type MutateInOptions

+ User []byte

type ObserveOptions

+ User []byte

type ObserveVbOptions

+ User []byte

type PingOptions

+ User []byte

type ReplaceOptions

+ User []byte

type SetMetaOptions

+ User []byte

type SetOptions

+ User []byte

type SingleServerStats

+ StatsChunks [][]byte

+ StatsKeys [][]byte

type StatsOptions

+ User []byte

type TouchOptions

+ User []byte

type UnlockOptions

+ User []byte

v9.0.8

Nov 17, 2020

Changes in this version

type KeyValueError

+ DocumentKey string

v9.0.7

Oct 20, 2020

Changes in this version

type Agent

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

+ type GetAllCollectionManifestsCallback func(*GetAllCollectionManifestsResult, error)

+ type GetAllCollectionManifestsOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetAllCollectionManifestsResult struct

+ Manifests map[string]SingleServerManifestResult

+ type SingleServerManifestResult struct

+ Error error

+ Manifest []byte

v9.0.6

Sep 15, 2020

Changes in this version

type DCPAgentConfig

+ DCPBufferSize int

v9.0.5

Aug 18, 2020

Changes in this version

+ var BucketNotReadyReason = retryReason

type AgentConfig

+ AuthMechanisms []AuthMechanism

+ DisableJSONHello bool

+ DisableSyncReplicationHello bool

+ DisableXErrors bool

type DCPAgentConfig

+ DisableJSONHello bool

+ DisableSyncReplicationHello bool

+ DisableXErrorHello bool

v9.0.4

Jul 21, 2020

Changes in this version

+ var MemdWriteFailure = retryReason

type Agent

+ func (agent *Agent) BucketName() string

type GetRandomOptions

+ CollectionID uint32

+ CollectionName string

+ ScopeName string

type LookupInResult

+ Internal struct{ ... }

v9.0.3

Jul 1, 2020

Changes in this version

+ var ConnectionErrorRetryReason = retryReason

+ var NoPipelineSnapshotRetryReason = retryReason

+ var NotReadyRetryReason = retryReason

type WaitUntilReadyOptions

+ RetryStrategy RetryStrategy

v9.0.2

Jun 16, 2020

Changes in this version

+ type AgentGroup struct

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

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

+ func (ag *AgentGroup) Close() error

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

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

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

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

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

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

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

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

+ func (ag *AgentGroup) ViewQuery(opts ViewQueryOptions, cb ViewQueryCallback) (PendingOp, error)

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

+ type AgentGroupConfig struct

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

type DCPAgentConfig

+ BackfillOrder DCPBackfillOrder

+ type DCPBackfillOrder uint8

+ const DCPBackfillOrderRoundRobin

+ const DCPBackfillOrderSequential

type PingOptions

+ MgmtDeadline time.Time

v9.0.1

May 19, 2020

Changes in this version

+ var ErrNotMyVBucket = errors.New("not my vbucket")

type AgentConfig

+ UseOutOfOrderResponses bool

type DCPAgentConfig

+ HTTPAddrs []string

+ HTTPIdleConnectionTimeout time.Duration

+ HTTPMaxIdleConns int

+ HTTPMaxIdleConnsPerHost int

+ HTTPRedialPeriod time.Duration

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

v9.0.0

Apr 21, 2020

Changes in this version

+ const BinaryType

+ const CapiService

+ const CbasService

+ const ClusterCapabilityEnhancedPreparedStatements

+ const ClusterStateDegraded

+ const ClusterStateOffline

+ const ClusterStateOnline

+ const DcpAgentPriorityHigh

+ const DcpAgentPriorityLow

+ const DcpAgentPriorityMed

+ const FtsService

+ const JSONType

+ const MemdService

+ const MgmtService

+ const N1qlService

+ const NoCompression

+ const PlainAuthMechanism

+ const ScramSha1AuthMechanism

+ const ScramSha256AuthMechanism

+ const ScramSha512AuthMechanism

+ const StringType

+ const UnknownCompression

+ const UnknownType

+ var AnalyticsTemporaryFailureRetryReason = retryReason

+ var CircuitBreakerOpenRetryReason = retryReason

+ var ErrAmbiguousTimeout = &dwError

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

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

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

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

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

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

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

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

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

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

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

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

+ var ErrDCPBackfillFailed = makeStreamEndStatusError(memd.StreamEndBackfillFailed)

+ var ErrDCPStreamClosed = makeStreamEndStatusError(memd.StreamEndClosed)

+ var ErrDCPStreamDisconnected = makeStreamEndStatusError(memd.StreamEndDisconnected)

+ var ErrDCPStreamFilterEmpty = makeStreamEndStatusError(memd.StreamEndFilterEmpty)

+ var ErrDCPStreamStateChanged = makeStreamEndStatusError(memd.StreamEndStateChanged)

+ var ErrDCPStreamTooSlow = makeStreamEndStatusError(memd.StreamEndTooSlow)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ var ErrGCCCPInUse = errors.New("connected via gcccp, kv operations are not supported, open a bucket first")

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

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

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

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

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

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

+ var ErrInvalidCertificate = errors.New("certificate is invalid")

+ var ErrInvalidCredentials = errors.New("an invalid set of credentials was provided")

+ var ErrInvalidReplica = errors.New("specific server index is invalid")

+ var ErrInvalidServer = errors.New("specific server index is invalid")

+ var ErrInvalidService = errors.New("invalid service")

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

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

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

+ var ErrMemdAccessError = makeKvStatusError(memd.StatusAccessError)

+ var ErrMemdAuthContinue = makeKvStatusError(memd.StatusAuthContinue)

+ var ErrMemdAuthError = makeKvStatusError(memd.StatusAuthError)

+ var ErrMemdAuthStale = makeKvStatusError(memd.StatusAuthStale)

+ var ErrMemdBadDelta = makeKvStatusError(memd.StatusBadDelta)

+ var ErrMemdBusy = makeKvStatusError(memd.StatusBusy)

+ var ErrMemdCollectionNotFound = makeKvStatusError(memd.StatusCollectionUnknown)

+ var ErrMemdDurabilityImpossible = makeKvStatusError(memd.StatusDurabilityImpossible)

+ var ErrMemdDurabilityInvalidLevel = makeKvStatusError(memd.StatusDurabilityInvalidLevel)

+ var ErrMemdInternalError = makeKvStatusError(memd.StatusInternalError)

+ var ErrMemdInvalidArgs = makeKvStatusError(memd.StatusInvalidArgs)

+ var ErrMemdKeyExists = makeKvStatusError(memd.StatusKeyExists)

+ var ErrMemdKeyNotFound = makeKvStatusError(memd.StatusKeyNotFound)

+ var ErrMemdLocked = makeKvStatusError(memd.StatusLocked)

+ var ErrMemdNoBucket = makeKvStatusError(memd.StatusNoBucket)

+ var ErrMemdNotInitialized = makeKvStatusError(memd.StatusNotInitialized)

+ var ErrMemdNotMyVBucket = makeKvStatusError(memd.StatusNotMyVBucket)

+ var ErrMemdNotStored = makeKvStatusError(memd.StatusNotStored)

+ var ErrMemdNotSupported = makeKvStatusError(memd.StatusNotSupported)

+ var ErrMemdOutOfMemory = makeKvStatusError(memd.StatusOutOfMemory)

+ var ErrMemdRangeError = makeKvStatusError(memd.StatusRangeError)

+ var ErrMemdRollback = makeKvStatusError(memd.StatusRollback)

+ var ErrMemdScopeNotFound = makeKvStatusError(memd.StatusScopeUnknown)

+ var ErrMemdSubDocBadCombo = makeKvStatusError(memd.StatusSubDocBadCombo)

+ var ErrMemdSubDocBadDelta = makeKvStatusError(memd.StatusSubDocBadDelta)

+ var ErrMemdSubDocBadMulti = makeKvStatusError(memd.StatusSubDocBadMulti)

+ var ErrMemdSubDocBadRange = makeKvStatusError(memd.StatusSubDocBadRange)

+ var ErrMemdSubDocCantInsert = makeKvStatusError(memd.StatusSubDocCantInsert)

+ var ErrMemdSubDocDocTooDeep = makeKvStatusError(memd.StatusSubDocDocTooDeep)

+ var ErrMemdSubDocMultiPathFailureDeleted = makeKvStatusError(memd.StatusSubDocMultiPathFailureDeleted)

+ var ErrMemdSubDocNotJSON = makeKvStatusError(memd.StatusSubDocNotJSON)

+ var ErrMemdSubDocPathExists = makeKvStatusError(memd.StatusSubDocPathExists)

+ var ErrMemdSubDocPathInvalid = makeKvStatusError(memd.StatusSubDocPathInvalid)

+ var ErrMemdSubDocPathMismatch = makeKvStatusError(memd.StatusSubDocPathMismatch)

+ var ErrMemdSubDocPathNotFound = makeKvStatusError(memd.StatusSubDocPathNotFound)

+ var ErrMemdSubDocPathTooBig = makeKvStatusError(memd.StatusSubDocPathTooBig)

+ var ErrMemdSubDocSuccessDeleted = makeKvStatusError(memd.StatusSubDocSuccessDeleted)

+ var ErrMemdSubDocValueTooDeep = makeKvStatusError(memd.StatusSubDocValueTooDeep)

+ var ErrMemdSubDocXattrCannotModifyVAttr = makeKvStatusError(memd.StatusSubDocXattrCannotModifyVAttr)

+ var ErrMemdSubDocXattrInvalidFlagCombo = makeKvStatusError(memd.StatusSubDocXattrInvalidFlagCombo)

+ var ErrMemdSubDocXattrInvalidKeyCombo = makeKvStatusError(memd.StatusSubDocXattrInvalidKeyCombo)

+ var ErrMemdSubDocXattrUnknownMacro = makeKvStatusError(memd.StatusSubDocXattrUnknownMacro)

+ var ErrMemdSubDocXattrUnknownVAttr = makeKvStatusError(memd.StatusSubDocXattrUnknownVAttr)

+ var ErrMemdSyncWriteAmbiguous = makeKvStatusError(memd.StatusSyncWriteAmbiguous)

+ var ErrMemdSyncWriteInProgess = makeKvStatusError(memd.StatusSyncWriteInProgress)

+ var ErrMemdSyncWriteReCommitInProgress = makeKvStatusError(memd.StatusSyncWriteReCommitInProgress)

+ var ErrMemdTmpFail = makeKvStatusError(memd.StatusTmpFail)

+ var ErrMemdTooBig = makeKvStatusError(memd.StatusTooBig)

+ var ErrMemdUnknownCommand = makeKvStatusError(memd.StatusUnknownCommand)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ var ErrSocketClosed = io.EOF

+ var ErrStreamIDNotEnabled = errors.New("stream IDs have not been enabled on this stream")

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

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

+ var ErrUnambiguousTimeout = &dwError

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ var KVCollectionOutdatedRetryReason = retryReason

+ var KVErrMapRetryReason = retryReason

+ var KVLockedRetryReason = retryReason

+ var KVNotMyVBucketRetryReason = retryReason

+ var KVSyncWriteInProgressRetryReason = retryReason

+ var KVSyncWriteRecommitInProgressRetryReason = retryReason

+ var KVTemporaryFailureRetryReason = retryReason

+ var NodeNotAvailableRetryReason = retryReason

+ var PipelineOverloadedRetryReason = retryReason

+ var QueryIndexNotFoundRetryReason = retryReason

+ var QueryPreparedStatementFailureRetryReason = retryReason

+ var SearchTooManyRequestsRetryReason = retryReason

+ var ServiceNotAvailableRetryReason = retryReason

+ var ServiceResponseCodeIndicatedRetryReason = retryReason

+ var SocketCloseInFlightRetryReason = retryReason

+ var SocketNotAvailableRetryReason = retryReason

+ var UnknownRetryReason = retryReason

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

+ func ControlledBackoff(retryAttempts uint32) time.Duration

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

+ func EncodeCommonFlags(valueType DataType, compression CompressionType) uint32

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

+ func SaslAuthPlain(username, password string, client AuthClient, deadline time.Time, ...) error

+ func SaslAuthScramSha1(username, password string, client AuthClient, deadline time.Time, ...) error

+ func SaslAuthScramSha256(username, password string, client AuthClient, deadline time.Time, ...) error

+ func SaslAuthScramSha512(username, password string, client AuthClient, deadline time.Time, ...) error

+ func SetLogRedactionLevel(level LogRedactLevel)

+ func SetLogger(logger Logger)

+ func Version() string

+ type AddOptions struct

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type AdjoinCallback func(*AdjoinResult, error)

+ type AdjoinOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type AdjoinResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type Agent struct

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

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

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

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

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

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

+ func (agent *Agent) ClientID() string

+ func (agent *Agent) Close() error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (agent *Agent) HasCollectionsSupport() bool

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

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

+ func (agent *Agent) IsSecure() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (agent *Agent) UsingGCCCP() bool

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

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

+ type AgentConfig struct

+ Auth AuthProvider

+ BucketName string

+ CccpMaxWait time.Duration

+ CccpPollPeriod time.Duration

+ CircuitBreakerConfig CircuitBreakerConfig

+ CompressionMinRatio float64

+ CompressionMinSize int

+ ConnectTimeout time.Duration

+ DefaultRetryStrategy RetryStrategy

+ DisableDecompression bool

+ HTTPAddrs []string

+ HTTPIdleConnectionTimeout time.Duration

+ HTTPMaxIdleConns int

+ HTTPMaxIdleConnsPerHost int

+ HTTPRedialPeriod time.Duration

+ HTTPRetryDelay time.Duration

+ KVConnectTimeout time.Duration

+ KvPoolSize int

+ MaxQueueSize int

+ MemdAddrs []string

+ NetworkType string

+ NoRootTraceSpans bool

+ TLSRootCAProvider func() *x509.CertPool

+ Tracer RequestTracer

+ UseCollections bool

+ UseCompression bool

+ UseDurations bool

+ UseMutationTokens bool

+ UseTLS bool

+ UseZombieLogger bool

+ UserAgent string

+ ZombieLoggerInterval time.Duration

+ ZombieLoggerSampleSize int

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

+ type AnalyticsError struct

+ ClientContextID string

+ Endpoint string

+ Errors []AnalyticsErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ Statement string

+ func (e AnalyticsError) Error() string

+ func (e AnalyticsError) Unwrap() error

+ type AnalyticsErrorDesc struct

+ Code uint32

+ Message string

+ type AnalyticsQueryCallback func(*AnalyticsRowReader, error)

+ type AnalyticsQueryOptions struct

+ Deadline time.Time

+ Payload []byte

+ Priority int

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type AnalyticsRowReader struct

+ func (q *AnalyticsRowReader) Close() error

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

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

+ func (q AnalyticsRowReader) Err() error

+ type AuthCertRequest struct

+ Endpoint string

+ Service ServiceType

+ type AuthClient interface

+ Address func() string

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

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

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

+ SupportsFeature func(feature memd.HelloFeature) bool

+ type AuthCredsRequest struct

+ Endpoint string

+ Service ServiceType

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

+ type AuthMechanism string

+ type AuthProvider interface

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

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

+ SupportsNonTLS func() bool

+ SupportsTLS func() bool

+ type BackoffCalculator func(retryAttempts uint32) time.Duration

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

+ type BestEffortRetryStrategy struct

+ func NewBestEffortRetryStrategy(calculator BackoffCalculator) *BestEffortRetryStrategy

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

+ type BytesAndError struct

+ Bytes []byte

+ Err error

+ type Cas uint64

+ type CircuitBreakerCallback func(error) bool

+ type CircuitBreakerConfig struct

+ CanaryTimeout time.Duration

+ CompletionCallback CircuitBreakerCallback

+ Enabled bool

+ ErrorThresholdPercentage float64

+ RollingWindow time.Duration

+ SleepWindow time.Duration

+ VolumeThreshold int64

+ type CloseStreamCallback func(error)

+ type CloseStreamOptions struct

+ StreamOptions *CloseStreamStreamOptions

+ type CloseStreamStreamOptions struct

+ StreamID uint16

+ type ClusterCapability uint32

+ type ClusterState uint32

+ type CompressionType uint32

+ type ConfigSnapshot struct

+ func (pi ConfigSnapshot) BucketUUID() string

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

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

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

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

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

+ func (pi ConfigSnapshot) RevID() int64

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

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

+ type CounterCallback func(*CounterResult, error)

+ type CounterInOptions StoreInOptions

+ type CounterOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Delta uint64

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Initial uint64

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type CounterResult struct

+ Cas Cas

+ MutationToken MutationToken

+ Value uint64

+ type DCPAgent struct

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

+ func (agent *DCPAgent) Close() error

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

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

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

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

+ func (agent *DCPAgent) HasCollectionsSupport() bool

+ func (agent *DCPAgent) IsSecure() bool

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

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

+ type DCPAgentConfig struct

+ AgentPriority DcpAgentPriority

+ Auth AuthProvider

+ BucketName string

+ CccpMaxWait time.Duration

+ CccpPollPeriod time.Duration

+ CompressionMinRatio float64

+ CompressionMinSize int

+ ConnectTimeout time.Duration

+ DisableDecompression bool

+ KVConnectTimeout time.Duration

+ KvPoolSize int

+ MaxQueueSize int

+ MemdAddrs []string

+ NetworkType string

+ TLSRootCAProvider func() *x509.CertPool

+ UseCollections bool

+ UseCompression bool

+ UseExpiryOpcode bool

+ UseOSOBackfill bool

+ UseStreamID bool

+ UseTLS bool

+ UserAgent string

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

+ type DataType uint32

+ type DcpAgentPriority uint8

+ type DeleteCallback func(*DeleteResult, error)

+ type DeleteInOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags memd.SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type DeleteMetaCallback func(*DeleteMetaResult, error)

+ type DeleteMetaOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ Expiry uint32

+ Extra []byte

+ Flags uint32

+ Key []byte

+ Options uint32

+ RetryStrategy RetryStrategy

+ RevNo uint64

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type DeleteMetaResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type DeleteOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type DeleteResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type DiagnosticInfo struct

+ ConfigRev int64

+ MemdConns []MemdConnInfo

+ State ClusterState

+ type DiagnosticsOptions struct

+ type DoHTTPRequestCallback func(*HTTPResponse, error)

+ type EndpointPingResult struct

+ Endpoint string

+ Error error

+ ID string

+ Latency time.Duration

+ Scope string

+ State PingState

+ type EndpointState uint32

+ const EndpointStateConnected

+ const EndpointStateConnecting

+ const EndpointStateDisconnected

+ const EndpointStateDisconnecting

+ type ExecHelloResponse struct

+ Err error

+ SrvFeatures []memd.HelloFeature

+ type ExistsInOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Flags memd.SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type FailoverEntry struct

+ SeqNo SeqNo

+ VbUUID VbUUID

+ type GetAndLockCallback func(*GetAndLockResult, error)

+ type GetAndLockOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ LockTime uint32

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetAndLockResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetAndTouchCallback func(*GetAndTouchResult, error)

+ type GetAndTouchOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Expiry uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetAndTouchResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetAnyReplicaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetCallback func(*GetResult, error)

+ type GetCollectionIDCallback func(*GetCollectionIDResult, error)

+ type GetCollectionIDOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetCollectionIDResult struct

+ CollectionID uint32

+ ManifestID uint64

+ type GetCollectionManifestCallback func(*GetCollectionManifestResult, error)

+ type GetCollectionManifestOptions struct

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetCollectionManifestResult struct

+ Manifest []byte

+ type GetFailoverLogCallback func([]FailoverEntry, error)

+ type GetInOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Flags memd.SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetMetaCallback func(*GetMetaResult, error)

+ type GetMetaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetMetaResult struct

+ Cas Cas

+ Datatype uint8

+ Deleted uint32

+ Expiry uint32

+ Flags uint32

+ SeqNo SeqNo

+ Value []byte

+ type GetOneReplicaOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type GetRandomCallback func(*GetRandomResult, error)

+ type GetRandomOptions struct

+ Deadline time.Time

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type GetRandomResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Key []byte

+ Value []byte

+ type GetReplicaCallback func(*GetReplicaResult, error)

+ type GetReplicaResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetResult struct

+ Cas Cas

+ Datatype uint8

+ Flags uint32

+ Value []byte

+ type GetVBucketSeqnosCallback func([]VbSeqNoEntry, error)

+ type GetVbucketSeqnoFilterOptions struct

+ CollectionID uint32

+ type GetVbucketSeqnoOptions struct

+ FilterOptions *GetVbucketSeqnoFilterOptions

+ type HTTPError struct

+ Endpoint string

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ UniqueID string

+ func (e HTTPError) Error() string

+ func (e HTTPError) Unwrap() error

+ type HTTPRequest struct

+ Body []byte

+ ContentType string

+ Deadline time.Time

+ Endpoint string

+ Headers map[string]string

+ IsIdempotent bool

+ Method string

+ Password string

+ Path string

+ RetryStrategy RetryStrategy

+ Service ServiceType

+ TraceContext RequestSpanContext

+ UniqueID string

+ Username string

+ type HTTPResponse struct

+ Body io.ReadCloser

+ Endpoint string

+ StatusCode int

+ type KeyValueError struct

+ BucketName string

+ CollectionID uint32

+ CollectionName string

+ Context string

+ ErrorDescription string

+ ErrorName string

+ InnerError error

+ LastConnectionID string

+ LastDispatchedFrom string

+ LastDispatchedTo string

+ Opaque uint32

+ Ref string

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ ScopeName string

+ StatusCode memd.StatusCode

+ func (e KeyValueError) Error() string

+ func (e KeyValueError) Unwrap() error

+ type LogLevel int

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogMaxVerbosity

+ const LogSched

+ const LogTrace

+ const LogWarn

+ type LogRedactLevel int

+ const RedactFull

+ const RedactNone

+ const RedactPartial

+ type Logger interface

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

+ func DefaultStdioLogger() Logger

+ func VerboseStdioLogger() Logger

+ type LookupInCallback func(*LookupInResult, error)

+ type LookupInOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Flags memd.SubdocDocFlag

+ Key []byte

+ Ops []SubDocOp

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type LookupInResult struct

+ Cas Cas

+ Ops []SubDocResult

+ type Manifest struct

+ Scopes []ManifestScope

+ UID uint64

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

+ type ManifestCollection struct

+ Name string

+ UID uint32

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

+ type ManifestScope struct

+ Collections []ManifestCollection

+ Name string

+ UID uint32

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

+ type MemdConnInfo struct

+ ID string

+ LastActivity time.Time

+ LocalAddr string

+ RemoteAddr string

+ Scope string

+ State EndpointState

+ type MutateInCallback func(*MutateInResult, error)

+ type MutateInOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags memd.SubdocDocFlag

+ Key []byte

+ Ops []SubDocOp

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type MutateInResult struct

+ Cas Cas

+ MutationToken MutationToken

+ Ops []SubDocResult

+ type MutationToken struct

+ SeqNo SeqNo

+ VbID uint16

+ VbUUID VbUUID

+ type N1QLError struct

+ ClientContextID string

+ Endpoint string

+ Errors []N1QLErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ Statement string

+ func (e N1QLError) Error() string

+ func (e N1QLError) Unwrap() error

+ type N1QLErrorDesc struct

+ Code uint32

+ Message string

+ type N1QLQueryCallback func(*N1QLRowReader, error)

+ type N1QLQueryOptions struct

+ Deadline time.Time

+ Payload []byte

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type N1QLRowReader struct

+ func (q *N1QLRowReader) Close() error

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

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

+ func (q N1QLRowReader) Err() error

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

+ type NoRetryRetryAction struct

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

+ type ObserveCallback func(*ObserveResult, error)

+ type ObserveOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type ObserveResult struct

+ Cas Cas

+ KeyState memd.KeyState

+ type ObserveVbCallback func(*ObserveVbResult, error)

+ type ObserveVbOptions struct

+ Deadline time.Time

+ ReplicaIdx int

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ VbID uint16

+ VbUUID VbUUID

+ type ObserveVbResult struct

+ CurrentSeqNo SeqNo

+ DidFailover bool

+ LastSeqNo SeqNo

+ OldVbUUID VbUUID

+ PersistSeqNo SeqNo

+ VbID uint16

+ VbUUID VbUUID

+ type OpenStreamCallback func([]FailoverEntry, error)

+ type OpenStreamFilterOptions struct

+ CollectionIDs []uint32

+ ScopeID uint32

+ type OpenStreamManifestOptions struct

+ ManifestUID uint64

+ type OpenStreamOptions struct

+ FilterOptions *OpenStreamFilterOptions

+ ManifestOptions *OpenStreamManifestOptions

+ StreamOptions *OpenStreamStreamOptions

+ type OpenStreamStreamOptions struct

+ StreamID uint16

+ type PasswordAuthProvider struct

+ Password string

+ Username string

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

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

+ func (auth PasswordAuthProvider) SupportsNonTLS() bool

+ func (auth PasswordAuthProvider) SupportsTLS() bool

+ type PendingOp interface

+ Cancel func()

+ type PingCallback func(*PingResult, error)

+ type PingOptions struct

+ CapiDeadline time.Time

+ CbasDeadline time.Time

+ FtsDeadline time.Time

+ KVDeadline time.Time

+ N1QLDeadline time.Time

+ ServiceTypes []ServiceType

+ TraceContext RequestSpanContext

+ type PingResult struct

+ ConfigRev int64

+ Services map[ServiceType][]EndpointPingResult

+ type PingState uint32

+ const PingStateError

+ const PingStateOK

+ const PingStateTimeout

+ type ReplaceOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type RequestSpan interface

+ Context func() RequestSpanContext

+ Finish func()

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

+ type RequestSpanContext interface

+ type RequestTracer interface

+ StartSpan func(operationName string, parentContext RequestSpanContext) RequestSpan

+ type RetryAction interface

+ Duration func() time.Duration

+ type RetryReason interface

+ AllowsNonIdempotentRetry func() bool

+ AlwaysRetry func() bool

+ Description func() string

+ type RetryRequest interface

+ Idempotent func() bool

+ Identifier func() string

+ RetryAttempts func() uint32

+ RetryReasons func() []RetryReason

+ type RetryStrategy interface

+ RetryAfter func(req RetryRequest, reason RetryReason) RetryAction

+ type SaslListMechsCompleted struct

+ Err error

+ Mechs []AuthMechanism

+ type SearchError struct

+ Endpoint string

+ ErrorText string

+ HTTPResponseCode int

+ IndexName string

+ InnerError error

+ Query interface{}

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ func (e SearchError) Error() string

+ func (e SearchError) Unwrap() error

+ type SearchQueryCallback func(*SearchRowReader, error)

+ type SearchQueryOptions struct

+ Deadline time.Time

+ IndexName string

+ Payload []byte

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ type SearchRowReader struct

+ func (q *SearchRowReader) Close() error

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

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

+ func (q SearchRowReader) Err() error

+ type SeqNo uint64

+ type ServiceType int

+ type SetMetaCallback func(*SetMetaResult, error)

+ type SetMetaOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ Expiry uint32

+ Extra []byte

+ Flags uint32

+ Key []byte

+ Options uint32

+ RetryStrategy RetryStrategy

+ RevNo uint64

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type SetMetaResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type SetOptions struct

+ CollectionID uint32

+ CollectionName string

+ Datatype uint8

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout time.Duration

+ Expiry uint32

+ Flags uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type SingleServerStats struct

+ Error error

+ Stats map[string]string

+ type SnapshotState uint32

+ func (s SnapshotState) HasInMemory() bool

+ func (s SnapshotState) HasOnDisk() bool

+ type StatsCallback func(*StatsResult, error)

+ type StatsOptions struct

+ Deadline time.Time

+ Key string

+ RetryStrategy RetryStrategy

+ Target StatsTarget

+ TraceContext RequestSpanContext

+ type StatsResult struct

+ Servers map[string]SingleServerStats

+ type StatsTarget interface

+ type StoreCallback func(*StoreResult, error)

+ type StoreInOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ DurabilityLevel memd.DurabilityLevel

+ DurabilityLevelTimeout uint16

+ Expiry uint32

+ Flags memd.SubdocFlag

+ Key []byte

+ Path string

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ Value []byte

+ type StoreResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type StreamObserver interface

+ CreateCollection func(seqNo uint64, version uint8, vbID uint16, manifestUID uint64, scopeID uint32, ...)

+ CreateScope func(seqNo uint64, version uint8, vbID uint16, manifestUID uint64, scopeID uint32, ...)

+ DeleteCollection func(seqNo uint64, version uint8, vbID uint16, manifestUID uint64, scopeID uint32, ...)

+ DeleteScope func(seqNo uint64, version uint8, vbID uint16, manifestUID uint64, scopeID uint32, ...)

+ Deletion func(seqNo, revNo uint64, deleteTime uint32, cas uint64, datatype uint8, ...)

+ End func(vbID uint16, streamID uint16, err error)

+ Expiration func(seqNo, revNo uint64, deleteTime uint32, cas uint64, vbID uint16, ...)

+ FlushCollection func(seqNo uint64, version uint8, vbID uint16, manifestUID uint64, ...)

+ ModifyCollection func(seqNo uint64, version uint8, vbID uint16, manifestUID uint64, ...)

+ Mutation func(seqNo, revNo uint64, flags, expiry, lockTime uint32, cas uint64, ...)

+ OSOSnapshot func(vbID uint16, snapshotType uint32, streamID uint16)

+ SeqNoAdvanced func(vbID uint16, bySeqno uint64, streamID uint16)

+ SnapshotMarker func(startSeqNo, endSeqNo uint64, vbID uint16, streamID uint16, ...)

+ type SubDocOp struct

+ Flags memd.SubdocFlag

+ Op memd.SubDocOpType

+ Path string

+ Value []byte

+ type SubDocResult struct

+ Err error

+ Value []byte

+ type SubDocumentError struct

+ Index int

+ InnerError error

+ func (err SubDocumentError) Error() string

+ func (err SubDocumentError) Unwrap() error

+ type TouchCallback func(*TouchResult, error)

+ type TouchOptions struct

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Expiry uint32

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type TouchResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type UnlockCallback func(*UnlockResult, error)

+ type UnlockOptions struct

+ Cas Cas

+ CollectionID uint32

+ CollectionName string

+ Deadline time.Time

+ Key []byte

+ RetryStrategy RetryStrategy

+ ScopeName string

+ TraceContext RequestSpanContext

+ type UnlockResult struct

+ Cas Cas

+ MutationToken MutationToken

+ type UserPassPair struct

+ Password string

+ Username string

+ type VBucketIDStatsTarget struct

+ VbID uint16

+ type VbSeqNoEntry struct

+ SeqNo SeqNo

+ VbID uint16

+ type VbUUID uint64

+ type ViewError struct

+ DesignDocumentName string

+ Endpoint string

+ Errors []ViewQueryErrorDesc

+ InnerError error

+ RetryAttempts uint32

+ RetryReasons []RetryReason

+ ViewName string

+ func (e ViewError) Error() string

+ func (e ViewError) Unwrap() error

+ type ViewQueryCallback func(*ViewQueryRowReader, error)

+ type ViewQueryErrorDesc struct

+ Message string

+ SourceNode string

+ type ViewQueryOptions struct

+ Deadline time.Time

+ DesignDocumentName string

+ Options url.Values

+ RetryStrategy RetryStrategy

+ TraceContext RequestSpanContext

+ ViewName string

+ ViewType string

+ type ViewQueryRowReader struct

+ func (q *ViewQueryRowReader) Close() error

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

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

+ func (q ViewQueryRowReader) Err() error

+ type WaitUntilReadyCallback func(*WaitUntilReadyResult, error)

+ type WaitUntilReadyOptions struct

+ DesiredState ClusterState

+ ServiceTypes []ServiceType

+ type WaitUntilReadyResult struct

+ type WithDurationRetryAction struct

+ WithDuration time.Duration

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

Other modules containing this package

github.com/couchbase/gocbcore

github.com/couchbase/gocbcore/v10

github.com/couchbase/gocbcore/v8

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