gocb

Mar 17, 2020

Changes in this version

+ var ErrNoHosts = errors.New(...)

Oct 17, 2019

Changes in this version

type QueryResults

+ Profile func() interface{}

Jun 19, 2019

Changes in this version

type SearchResultStatus

+ Errors interface{}

Mar 15, 2019

Changes in this version

type SearchResultHit

+ AllFields map[string]interface{}

Dec 17, 2018

Changes in this version

type ClusterManager

+ func (cm *ClusterManager) Internal() *ClusterManagerInternal

+ type ClusterManagerInternal struct

+ func (cmi *ClusterManagerInternal) GetNodesMetadata() ([]NodeMetadata, error)

+ 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

Nov 14, 2018

Changes in this version

+ func IngestMethodInsert(bucket *Bucket, key string, val interface{}) error

+ func IngestMethodReplace(bucket *Bucket, key string, val interface{}) error

+ func IngestMethodUpsert(bucket *Bucket, key string, val interface{}) error

+ func IsStatusBusyError(err error) bool

+ func IsTmpFailError(err error) bool

+ func PassthroughDataConverterFunction(docBytes []byte) (interface{}, error)

+ func UUIDIdGeneratorFunction(doc interface{}) (string, error)

+ type AnalyticsDeferredResultHandle interface

+ Close func() error

+ Next func(valuePtr interface{}) bool

+ NextBytes func() []byte

+ One func(valuePtr interface{}) error

+ Status func() (string, error)

+ type AnalyticsIngestOptions struct

+ func DefaultAnalyticsIngestOptions() *AnalyticsIngestOptions

+ func (ai *AnalyticsIngestOptions) AnalyticsTimeout(timeout time.Duration) *AnalyticsIngestOptions

+ func (ai *AnalyticsIngestOptions) DataConverter(fn DataConverterFunction) *AnalyticsIngestOptions

+ func (ai *AnalyticsIngestOptions) IdGenerator(fn IdGeneratorFunction) *AnalyticsIngestOptions

+ func (ai *AnalyticsIngestOptions) IgnoreIngestError(ignore bool) *AnalyticsIngestOptions

+ func (ai *AnalyticsIngestOptions) IngestMethod(method ingestMethod) *AnalyticsIngestOptions

+ func (ai *AnalyticsIngestOptions) KVRetryBehavior(behavior QueryRetryBehavior) *AnalyticsIngestOptions

+ func (ai *AnalyticsIngestOptions) KVRetryOn(errors []error) *AnalyticsIngestOptions

type AnalyticsQuery

+ func (aq *AnalyticsQuery) Deferred(deferred bool) *AnalyticsQuery

type AnalyticsResults

+ Handle func() AnalyticsDeferredResultHandle

type Bucket

+ func (b *Bucket) AnalyticsIngest(analyticsQuery *AnalyticsQuery, analyticsParams []interface{}, ...) error

+ type DataConverterFunction func(docBytes []byte) (interface{}, error)

+ type IdGeneratorFunction func(doc interface{}) (string, error)

Sep 19, 2018

Changes in this version

+ func QueryExponentialDelayFunction(retryDelay uint, retries uint) time.Duration

+ func QueryLinearDelayFunction(retryDelay uint, retries uint) time.Duration

type AnalyticsQuery

+ func (aq *AnalyticsQuery) ContextId(clientContextId string) *AnalyticsQuery

+ func (aq *AnalyticsQuery) Pretty(pretty bool) *AnalyticsQuery

+ func (aq *AnalyticsQuery) Priority(priority bool) *AnalyticsQuery

+ func (aq *AnalyticsQuery) RawParam(name string, value interface{}) *AnalyticsQuery

+ func (aq *AnalyticsQuery) ServerSideTimeout(timeout time.Duration) *AnalyticsQuery

+ type AnalyticsResultMetrics struct

+ ElapsedTime time.Duration

+ ErrorCount uint

+ ExecutionTime time.Duration

+ MutationCount uint

+ ProcessedObjects uint

+ ResultCount uint

+ ResultSize uint

+ SortCount uint

+ WarningCount uint

type AnalyticsResults

+ Metrics func() AnalyticsResultMetrics

+ Signature func() interface{}

+ Status func() string

+ Warnings func() []AnalyticsWarning

+ type AnalyticsWarning struct

+ Code uint32

+ Message string

type Bucket

+ func (b *Bucket) AnalyticsTimeout() time.Duration

+ func (b *Bucket) ExecuteAnalyticsQuery(q *AnalyticsQuery, params interface{}) (AnalyticsResults, error)

+ func (b *Bucket) SetAnalyticsQueryRetryBehavior(retryBehavior QueryRetryBehavior)

+ func (b *Bucket) SetAnalyticsTimeout(timeout time.Duration)

+ func (b *Bucket) SetSearchQueryRetryBehavior(retryBehavior QueryRetryBehavior)

+ type QueryDelayRetryBehavior struct

+ func NewQueryDelayRetryBehavior(maxRetries uint, retryDelay uint, delayLimit time.Duration, ...) *QueryDelayRetryBehavior

+ func (rb *QueryDelayRetryBehavior) CanRetry(retries uint) bool

+ func (rb *QueryDelayRetryBehavior) NextInterval(retries uint) time.Duration

+ type QueryRetryBehavior interface

+ CanRetry func(retries uint) bool

+ NextInterval func(retries uint) time.Duration

+ type QueryRetryDelayFunction func(retryDelay uint, retries uint) time.Duration

Aug 21, 2018

Changes in this version

+ var ErrNonZeroCas = gocbcore.ErrNonZeroCas

type ThresholdLoggingTracer

+ AnalyticsThreshold time.Duration

+ Interval time.Duration

+ KvThreshold time.Duration

+ N1qlThreshold time.Duration

+ SearchThreshold time.Duration

+ ViewsThreshold time.Duration

Jun 26, 2018

Changes in this version

+ var ErrMixedAuthentication = errors.New(...)

+ var ErrMixedCertAuthentication = errors.New(...)

+ type CertAuthenticator struct

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

type SearchIndexManager

+ func (sim *SearchIndexManager) GetAllIndexDefinitions() ([]interface{}, error)

+ func (sim *SearchIndexManager) GetIndexDefinition(indexName string) (interface{}, error)

May 16, 2018

Changes in this version

+ const SearchIndexIngestControlOpPause

+ const SearchIndexIngestControlOpResume

+ const SearchIndexPlanFreezeControlOpPause

+ const SearchIndexPlanFreezeControlOpResume

+ const SearchIndexQueryControlOpPause

+ const SearchIndexQueryControlOpResume

+ const SearchIndexSourceTypeCouchbase

+ const SearchIndexSourceTypeMemcached

+ var ErrSearchIndexAlreadyExists = errors.New("The search index specified already exists.")

+ var ErrSearchIndexInvalidIngestControlOp = errors.New("An invalid search index ingest control op was specified.")

+ var ErrSearchIndexInvalidName = errors.New("An invalid search index name was specified.")

+ var ErrSearchIndexInvalidPlanFreezeControlOp = errors.New("An invalid search index plan freeze control op was specified.")

+ var ErrSearchIndexInvalidQueryControlOp = errors.New("An invalid search index query control op was specified.")

+ var ErrSearchIndexInvalidSourceName = errors.New("An invalid search index source name was specified.")

+ var ErrSearchIndexInvalidSourceType = errors.New("An invalid search index source type was specified.")

+ var ErrSearchIndexMissingType = errors.New("No search index type was specified.")

type Bucket

+ func (b *Bucket) MutateInExDura(key string, flags SubdocDocFlag, cas Cas, expiry uint32, ...) *MutateInBuilder

type ClusterManager

+ func (cm *ClusterManager) SearchIndexManager() *SearchIndexManager

+ type SearchIndexDefinitionBuilder struct

+ func (b *SearchIndexDefinitionBuilder) AddField(name string, value interface{}) *SearchIndexDefinitionBuilder

+ type SearchIndexManager struct

+ func (sim *SearchIndexManager) CreateIndex(builder SearchIndexDefinitionBuilder) error

+ func (sim *SearchIndexManager) DeleteIndex(indexName string) (bool, error)

+ func (sim *SearchIndexManager) GetAllIndexPartitionInfo() (interface{}, error)

+ func (sim *SearchIndexManager) GetAllIndexStats() (interface{}, error)

+ func (sim *SearchIndexManager) GetIndex(indexName string) (interface{}, error)

+ func (sim *SearchIndexManager) GetIndexPartitionIndexedDocumentCount(pIndexName string) (int, error)

+ func (sim *SearchIndexManager) GetIndexPartitionInfo(pIndexName string) (interface{}, error)

+ func (sim *SearchIndexManager) GetIndexStats(indexName string) (interface{}, error)

+ func (sim *SearchIndexManager) GetIndexedDocumentCount(indexName string) (int, error)

+ func (sim *SearchIndexManager) GetIndexes() ([]interface{}, error)

+ func (sim *SearchIndexManager) SetIndexIngestion(indexName string, op string) (bool, error)

+ func (sim *SearchIndexManager) SetIndexPlanFreeze(indexName string, op string) (bool, error)

+ func (sim *SearchIndexManager) SetIndexQuerying(indexName string, op string) (bool, error)

Mar 23, 2018

Changes in this version

+ const QueryProfileNone

+ const QueryProfilePhases

+ const QueryProfileTimings

+ const RedactFull

+ const RedactNone

+ const RedactPartial

+ func SetLogRedactionLevel(level LogRedactLevel)

type Cluster

+ func (c *Cluster) Close() error

+ func (c *Cluster) SetTracer(tracer opentracing.Tracer)

+ type LogRedactLevel int

type N1qlQuery

+ func (nq *N1qlQuery) Profile(profileMode QueryProfileType) *N1qlQuery

+ type QueryProfileType string

+ type ThresholdLoggingTracer struct

+ AnalyticsFloor time.Duration

+ KvFloor time.Duration

+ QueryFloor time.Duration

+ SampleSize uint32

+ SearchFloor time.Duration

+ TickInterval time.Duration

+ ViewsFloor time.Duration

+ func (t *ThresholdLoggingTracer) AddRef() int32

+ func (t *ThresholdLoggingTracer) DecRef() int32

+ func (t *ThresholdLoggingTracer) Extract(format interface{}, carrier interface{}) (opentracing.SpanContext, error)

+ func (t *ThresholdLoggingTracer) Inject(sp opentracing.SpanContext, format interface{}, carrier interface{}) error

+ func (t *ThresholdLoggingTracer) StartSpan(operationName string, opts ...opentracing.StartSpanOption) opentracing.Span

Jan 17, 2018

Changes in this version

+ const DiagStateDisconnected

+ const DiagStateOk

+ func Version() string

type Bucket

+ func (b *Bucket) Ping(services []ServiceType) (*PingReport, error)

+ func (bucket *Bucket) Diagnostics() (*DiagnosticReport, error)

+ type CertificateAuthenticator struct

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

+ type DiagConnState int

+ type DiagnosticEntry struct

+ LastActivity time.Time

+ LocalAddr string

+ RemoteAddr string

+ Service ServiceType

+ State DiagConnState

+ type DiagnosticReport struct

+ ConfigRev int64

+ Services []DiagnosticEntry

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

+ type PingReport struct

+ Services []PingServiceEntry

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

+ type PingServiceEntry struct

+ Endpoint string

+ Latency time.Duration

+ Service ServiceType

+ Success bool

type QueryResults

+ SourceEndpoint func() string

Dec 29, 2017

Changes in this version

+ const CapiService

+ const CbasService

+ const FtsService

+ const MemdService

+ const MgmtService

+ const N1qlService

+ var ErrInvalidCredentials = gocbcore.ErrInvalidCredentials

+ type AuthCredsRequest struct

+ Bucket string

+ Endpoint string

+ Service ServiceType

type Authenticator

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

type ClusterAuthenticator

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

type PasswordAuthenticator

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

+ type ServiceType gocbcore.ServiceType

+ type UserPassPair gocbcore.UserPassPair

Aug 24, 2017

Changes in this version

+ func ErrorCause(err error) error

type Cluster

+ func (c *Cluster) EnhancedErrors() bool

+ func (c *Cluster) SetEnhancedErrors(enabled bool)

type N1qlQuery

+ func (nq *N1qlQuery) PipelineBatch(pipelineBatch int) *N1qlQuery

+ func (nq *N1qlQuery) PipelineCap(pipelineCap int) *N1qlQuery

+ func (nq *N1qlQuery) ReadOnly(readOnly bool) *N1qlQuery

+ func (nq *N1qlQuery) ScanCap(scanCap int) *N1qlQuery

Jul 18, 2017

Changes in this version

+ var ErrCliInternalError = gocbcore.ErrCliInternalError

+ func IsKeyExistsError(err error) bool

+ func IsKeyNotFoundError(err error) bool

+ type AuthDomain string

+ const ExternalDomain

+ const LocalDomain

type ClusterManager

+ func (cm *ClusterManager) GetUser(domain AuthDomain, name string) (*User, error)

May 23, 2017

Changes in this version

+ const Ephemeral

+ const SubdocDocFlagAccessDeleted

+ const SubdocDocFlagMkDoc

+ const SubdocDocFlagNone

+ const SubdocDocFlagReplaceDoc

+ var ErrSubDocBadCombo = gocbcore.ErrSubDocBadCombo

+ var ErrSubDocBadDelta = gocbcore.ErrSubDocBadDelta

+ var ErrSubDocBadMulti = gocbcore.ErrSubDocBadMulti

+ var ErrSubDocBadRange = gocbcore.ErrSubDocBadRange

+ var ErrSubDocCantInsert = gocbcore.ErrSubDocCantInsert

+ var ErrSubDocDocTooDeep = gocbcore.ErrSubDocDocTooDeep

+ var ErrSubDocMultiPathFailureDeleted = gocbcore.ErrSubDocMultiPathFailureDeleted

+ var ErrSubDocNotJson = gocbcore.ErrSubDocNotJson

+ var ErrSubDocPathExists = gocbcore.ErrSubDocPathExists

+ var ErrSubDocPathInvalid = gocbcore.ErrSubDocPathInvalid

+ var ErrSubDocPathMismatch = gocbcore.ErrSubDocPathMismatch

+ var ErrSubDocPathNotFound = gocbcore.ErrSubDocPathNotFound

+ var ErrSubDocPathTooBig = gocbcore.ErrSubDocPathTooBig

+ var ErrSubDocSuccessDeleted = gocbcore.ErrSubDocSuccessDeleted

+ var ErrSubDocValueTooDeep = gocbcore.ErrSubDocValueTooDeep

+ var ErrSubDocXattrCannotModifyVAttr = gocbcore.ErrSubDocXattrCannotModifyVAttr

+ var ErrSubDocXattrInvalidFlagCombo = gocbcore.ErrSubDocXattrInvalidFlagCombo

+ var ErrSubDocXattrInvalidKeyCombo = gocbcore.ErrSubDocXattrInvalidKeyCombo

+ var ErrSubDocXattrUnknownMacro = gocbcore.ErrSubDocXattrUnknownMacro

+ var ErrSubDocXattrUnknownVAttr = gocbcore.ErrSubDocXattrUnknownVAttr

type Bucket

+ func (b *Bucket) LookupInEx(key string, flags SubdocDocFlag) *LookupInBuilder

+ func (b *Bucket) MutateInEx(key string, flags SubdocDocFlag, cas Cas, expiry uint32) *MutateInBuilder

+ func (b *Bucket) UUID() string

type LookupInBuilder

+ func (set *LookupInBuilder) GetCount(path string) *LookupInBuilder

+ func (set *LookupInBuilder) GetCountEx(path string, flags SubdocFlag) *LookupInBuilder

+ type PasswordAuthenticator struct

+ Password string

+ Username string

+ type SubdocDocFlag gocbcore.SubdocDocFlag

Apr 19, 2017

Changes in this version

+ const SubdocFlagAccessDeleted

+ type AnalyticsQuery struct

+ func NewAnalyticsQuery(statement string) *AnalyticsQuery

+ type AnalyticsResults interface

+ ClientContextId func() string

+ Close func() error

+ Next func(valuePtr interface{}) bool

+ NextBytes func() []byte

+ One func(valuePtr interface{}) error

+ RequestId func() string

type Cluster

+ func (c *Cluster) AnalyticsTimeout() time.Duration

+ func (c *Cluster) EnableAnalytics(hosts []string)

+ func (c *Cluster) ExecuteAnalyticsQuery(q *AnalyticsQuery) (AnalyticsResults, error)

+ func (c *Cluster) SetAnalyticsTimeout(timeout time.Duration)

+ type ViewResultMetrics interface

+ TotalRows func() int

Mar 28, 2017

Changes in this version

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogMaxVerbosity

+ const LogSched

+ const LogTrace

+ const LogWarn

+ const SubdocFlagCreateDoc

+ const SubdocFlagCreatePath

+ const SubdocFlagNone

+ const SubdocFlagUseMacros

+ const SubdocFlagXattr

+ func SetLogger(logger Logger)

type Bucket

+ func (b *Bucket) Name() string

type ClusterManager

+ func (cm *ClusterManager) GetUsers() ([]*User, error)

+ func (cm *ClusterManager) RemoveUser(name string) error

+ func (cm *ClusterManager) UpsertUser(name string, settings *UserSettings) error

+ type LogLevel gocbcore.LogLevel

+ type Logger interface

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

+ func DefaultStdioLogger() Logger

+ func VerboseStdioLogger() Logger

type LookupInBuilder

+ func (set *LookupInBuilder) ExistsEx(path string, flags SubdocFlag) *LookupInBuilder

+ func (set *LookupInBuilder) GetEx(path string, flags SubdocFlag) *LookupInBuilder

+ type MultiError struct

+ Errors []error

+ func (e *MultiError) Error() string

type MutateInBuilder

+ func (set *MutateInBuilder) ArrayAddUniqueEx(path string, value interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayAppendEx(path string, value interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayAppendMultiEx(path string, values interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayInsertEx(path string, value interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayInsertMultiEx(path string, values interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayPrependEx(path string, value interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayPrependMultiEx(path string, values interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) CounterEx(path string, delta int64, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) InsertEx(path string, value interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) RemoveEx(path string, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) ReplaceEx(path string, value interface{}, flags SubdocFlag) *MutateInBuilder

+ func (set *MutateInBuilder) UpsertEx(path string, value interface{}, flags SubdocFlag) *MutateInBuilder

+ type RbacAuthenticator struct

+ Password string

+ Username string

+ type SubdocFlag gocbcore.SubdocFlag

+ type User struct

+ Id string

+ Name string

+ Roles []UserRole

+ Type string

+ type UserRole struct

+ BucketName string

+ Role string

+ type UserSettings struct

+ Name string

+ Password string

+ Roles []UserRole

Dec 21, 2016

Changes in this version

+ const After

+ const AnsiHightlightStyle

+ const Ascending

+ const Before

+ const Couchbase

+ const DefaultHighlightStyle

+ const Descending

+ const HtmlHighlightStyle

+ const IndexTypeN1ql

+ const IndexTypeView

+ const Memcached

+ const None

+ const NotBounded

+ const RequestPlus

+ const StatementPlus

+ var ErrAccessError = gocbcore.ErrAccessError

+ var ErrAuthError = gocbcore.ErrAuthError

+ var ErrBadHosts = gocbcore.ErrBadHosts

+ var ErrBusy = gocbcore.ErrBusy

+ var ErrDispatchFail = gocbcore.ErrDispatchFail

+ var ErrDurabilityTimeout = errors.New("Failed to meet durability requirements in time.")

+ var ErrFacetNoRanges = errors.New("At least one range must be specified on a facet.")

+ var ErrIndexAlreadyExists = errors.New("The index specified already exists.")

+ var ErrIndexInvalidName = errors.New("An invalid index name was specified.")

+ var ErrIndexNoFields = errors.New("You must specify at least one field to index.")

+ var ErrIndexNotFound = errors.New("The index specified does not exist.")

+ var ErrInternalError = gocbcore.ErrInternalError

+ var ErrInvalidCert = gocbcore.ErrInvalidCert

+ var ErrInvalidReplica = gocbcore.ErrInvalidReplica

+ var ErrInvalidServer = gocbcore.ErrInvalidServer

+ var ErrInvalidVBucket = gocbcore.ErrInvalidVBucket

+ var ErrKeyExists = gocbcore.ErrKeyExists

+ var ErrKeyNotFound = gocbcore.ErrKeyNotFound

+ var ErrNetwork = gocbcore.ErrNetwork

+ var ErrNoOpenBuckets = errors.New("You must open a bucket before you can perform cluster level operations.")

+ var ErrNoReplicas = gocbcore.ErrNoReplicas

+ var ErrNoResults = errors.New("No results returned.")

+ var ErrNotEnoughReplicas = errors.New("Not enough replicas to match durability requirements.")

+ var ErrNotStored = gocbcore.ErrNotStored

+ var ErrNotSupported = gocbcore.ErrNotSupported

+ var ErrOutOfMemory = gocbcore.ErrOutOfMemory

+ var ErrOverload = gocbcore.ErrOverload

+ var ErrProtocol = gocbcore.ErrProtocol

+ var ErrRangeError = gocbcore.ErrRangeError

+ var ErrRollback = gocbcore.ErrRollback

+ var ErrShutdown = gocbcore.ErrShutdown

+ var ErrStreamClosed = gocbcore.ErrStreamClosed

+ var ErrStreamDisconnected = gocbcore.ErrStreamDisconnected

+ var ErrStreamStateChanged = gocbcore.ErrStreamStateChanged

+ var ErrStreamTooSlow = gocbcore.ErrStreamTooSlow

+ var ErrTimeout = gocbcore.ErrTimeout

+ var ErrTmpFail = gocbcore.ErrTmpFail

+ var ErrTooBig = gocbcore.ErrTooBig

+ type AppendOp struct

+ Cas Cas

+ Err error

+ Key string

+ Value string

+ type Authenticator interface

+ type Bucket struct

+ func (b *Bucket) Append(key, value string) (Cas, error)

+ func (b *Bucket) AppendDura(key, value string, replicateTo, persistTo uint) (Cas, error)

+ func (b *Bucket) AppendMt(key, value string) (Cas, MutationToken, error)

+ func (b *Bucket) BulkOperationTimeout() time.Duration

+ func (b *Bucket) Close()

+ func (b *Bucket) Counter(key string, delta, initial int64, expiry uint32) (uint64, Cas, error)

+ func (b *Bucket) CounterDura(key string, delta, initial int64, expiry uint32, replicateTo, persistTo uint) (uint64, Cas, error)

+ func (b *Bucket) CounterMt(key string, delta, initial int64, expiry uint32) (uint64, Cas, MutationToken, error)

+ func (b *Bucket) Do(ops []BulkOp) error

+ func (b *Bucket) DurabilityPollTimeout() time.Duration

+ func (b *Bucket) DurabilityTimeout() time.Duration

+ func (b *Bucket) ExecuteN1qlQuery(q *N1qlQuery, params interface{}) (QueryResults, error)

+ func (b *Bucket) ExecuteSearchQuery(q *SearchQuery) (SearchResults, error)

+ func (b *Bucket) ExecuteSpatialQuery(q *SpatialQuery) (ViewResults, error)

+ func (b *Bucket) ExecuteViewQuery(q *ViewQuery) (ViewResults, error)

+ func (b *Bucket) Get(key string, valuePtr interface{}) (Cas, error)

+ func (b *Bucket) GetAndLock(key string, lockTime uint32, valuePtr interface{}) (Cas, error)

+ func (b *Bucket) GetAndTouch(key string, expiry uint32, valuePtr interface{}) (Cas, error)

+ func (b *Bucket) GetReplica(key string, valuePtr interface{}, replicaIdx int) (Cas, error)

+ func (b *Bucket) Insert(key string, value interface{}, expiry uint32) (Cas, error)

+ func (b *Bucket) InsertDura(key string, value interface{}, expiry uint32, replicateTo, persistTo uint) (Cas, error)

+ func (b *Bucket) InsertMt(key string, value interface{}, expiry uint32) (Cas, MutationToken, error)

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

+ func (b *Bucket) InvalidateQueryCache()

+ func (b *Bucket) IoRouter() *gocbcore.Agent

+ func (b *Bucket) ListAppend(key string, value interface{}, createList bool) (Cas, error)

+ func (b *Bucket) ListGet(key string, index uint, valuePtr interface{}) (Cas, error)

+ func (b *Bucket) ListPrepend(key string, value interface{}, createList bool) (Cas, error)

+ func (b *Bucket) ListRemove(key string, index uint) (Cas, error)

+ func (b *Bucket) ListSet(key string, index uint, value interface{}) (Cas, error)

+ func (b *Bucket) ListSize(key string) (uint, Cas, error)

+ func (b *Bucket) LookupIn(key string) *LookupInBuilder

+ func (b *Bucket) Manager(username, password string) *BucketManager

+ func (b *Bucket) MapAdd(key, path string, value interface{}, createMap bool) (Cas, error)

+ func (b *Bucket) MapGet(key, path string, valuePtr interface{}) (Cas, error)

+ func (b *Bucket) MapRemove(key, path string) (Cas, error)

+ func (b *Bucket) MapSize(key string) (uint, Cas, error)

+ func (b *Bucket) MutateIn(key string, cas Cas, expiry uint32) *MutateInBuilder

+ func (b *Bucket) N1qlTimeout() time.Duration

+ func (b *Bucket) OperationTimeout() time.Duration

+ func (b *Bucket) Prepend(key, value string) (Cas, error)

+ func (b *Bucket) PrependDura(key, value string, replicateTo, persistTo uint) (Cas, error)

+ func (b *Bucket) PrependMt(key, value string) (Cas, MutationToken, error)

+ func (b *Bucket) QueuePop(key string, valuePtr interface{}) (Cas, error)

+ func (b *Bucket) QueuePush(key string, value interface{}, createQueue bool) (Cas, error)

+ func (b *Bucket) QueueSize(key string) (uint, Cas, error)

+ func (b *Bucket) Remove(key string, cas Cas) (Cas, error)

+ func (b *Bucket) RemoveDura(key string, cas Cas, replicateTo, persistTo uint) (Cas, error)

+ func (b *Bucket) RemoveMt(key string, cas Cas) (Cas, MutationToken, error)

+ func (b *Bucket) Replace(key string, value interface{}, cas Cas, expiry uint32) (Cas, error)

+ func (b *Bucket) ReplaceDura(key string, value interface{}, cas Cas, expiry uint32, ...) (Cas, error)

+ func (b *Bucket) ReplaceMt(key string, value interface{}, cas Cas, expiry uint32) (Cas, MutationToken, error)

+ func (b *Bucket) SetAdd(key string, value interface{}, createSet bool) (Cas, error)

+ func (b *Bucket) SetBulkOperationTimeout(timeout time.Duration)

+ func (b *Bucket) SetDurabilityPollTimeout(timeout time.Duration)

+ func (b *Bucket) SetDurabilityTimeout(timeout time.Duration)

+ func (b *Bucket) SetExists(key string, value interface{}) (bool, Cas, error)

+ func (b *Bucket) SetN1qlTimeout(timeout time.Duration)

+ func (b *Bucket) SetOperationTimeout(timeout time.Duration)

+ func (b *Bucket) SetRemove(key string, value interface{}) (Cas, error)

+ func (b *Bucket) SetSize(key string) (uint, Cas, error)

+ func (b *Bucket) SetTranscoder(transcoder Transcoder)

+ func (b *Bucket) SetViewTimeout(timeout time.Duration)

+ func (b *Bucket) Stats(key string) (statsOut ServerStats, errOut error)

+ func (b *Bucket) Touch(key string, cas Cas, expiry uint32) (Cas, error)

+ func (b *Bucket) TouchDura(key string, cas Cas, expiry uint32, replicateTo, persistTo uint) (Cas, error)

+ func (b *Bucket) Unlock(key string, cas Cas) (Cas, error)

+ func (b *Bucket) Upsert(key string, value interface{}, expiry uint32) (Cas, error)

+ func (b *Bucket) UpsertDura(key string, value interface{}, expiry uint32, replicateTo, persistTo uint) (Cas, error)

+ func (b *Bucket) UpsertMt(key string, value interface{}, expiry uint32) (Cas, MutationToken, error)

+ func (b *Bucket) ViewTimeout() time.Duration

+ type BucketAuthenticator struct

+ Password string

+ type BucketAuthenticatorMap map[string]BucketAuthenticator

+ type BucketInternal struct

+ func (bi *BucketInternal) GetRandom(valuePtr interface{}) (string, Cas, error)

+ func (bi *BucketInternal) RemoveMeta(key string, extra []byte, options, flags, expiry uint32, cas, revseqno uint64) (Cas, error)

+ func (bi *BucketInternal) UpsertMeta(key string, value, extra []byte, options, flags, expiry uint32, ...) (Cas, error)

+ type BucketManager struct

+ func (bm *BucketManager) BuildDeferredIndexes() ([]string, error)

+ func (bm *BucketManager) CreateIndex(indexName string, fields []string, ignoreIfExists, deferred bool) error

+ func (bm *BucketManager) CreatePrimaryIndex(customName string, ignoreIfExists, deferred bool) error

+ func (bm *BucketManager) DropIndex(indexName string, ignoreIfNotExists bool) error

+ func (bm *BucketManager) DropPrimaryIndex(customName string, ignoreIfNotExists bool) error

+ func (bm *BucketManager) Flush() error

+ func (bm *BucketManager) GetDesignDocument(name string) (*DesignDocument, error)

+ func (bm *BucketManager) GetDesignDocuments() ([]*DesignDocument, error)

+ func (bm *BucketManager) GetIndexes() ([]IndexInfo, error)

+ func (bm *BucketManager) InsertDesignDocument(ddoc *DesignDocument) error

+ func (bm *BucketManager) RemoveDesignDocument(name string) error

+ func (bm *BucketManager) UpsertDesignDocument(ddoc *DesignDocument) error

+ func (bm *BucketManager) WatchIndexes(watchList []string, watchPrimary bool, timeout time.Duration) error

+ type BucketSettings struct

+ FlushEnabled bool

+ IndexReplicas bool

+ Name string

+ Password string

+ Quota int

+ Replicas int

+ Type BucketType

+ type BucketType int

+ type BulkOp interface

+ type Cas gocbcore.Cas

+ type Cluster struct

+ func Connect(connSpecStr string) (*Cluster, error)

+ func (c *Cluster) Authenticate(auth Authenticator) error

+ func (c *Cluster) ConnectTimeout() time.Duration

+ func (c *Cluster) ExecuteN1qlQuery(q *N1qlQuery, params interface{}) (QueryResults, error)

+ func (c *Cluster) ExecuteSearchQuery(q *SearchQuery) (SearchResults, error)

+ func (c *Cluster) FtsTimeout() time.Duration

+ func (c *Cluster) InvalidateQueryCache()

+ func (c *Cluster) Manager(username, password string) *ClusterManager

+ func (c *Cluster) N1qlTimeout() time.Duration

+ func (c *Cluster) NmvRetryDelay() time.Duration

+ func (c *Cluster) OpenBucket(bucket, password string) (*Bucket, error)

+ func (c *Cluster) OpenBucketWithMt(bucket, password string) (*Bucket, error)

+ func (c *Cluster) OpenStreamingBucket(streamName, bucket, password string) (*StreamingBucket, error)

+ func (c *Cluster) ServerConnectTimeout() time.Duration

+ func (c *Cluster) SetConnectTimeout(timeout time.Duration)

+ func (c *Cluster) SetFtsTimeout(timeout time.Duration)

+ func (c *Cluster) SetN1qlTimeout(timeout time.Duration)

+ func (c *Cluster) SetNmvRetryDelay(delay time.Duration)

+ func (c *Cluster) SetServerConnectTimeout(timeout time.Duration)

+ type ClusterAuthenticator struct

+ Buckets BucketAuthenticatorMap

+ Password string

+ Username string

+ type ClusterManager struct

+ func (cm *ClusterManager) GetBuckets() ([]*BucketSettings, error)

+ func (cm *ClusterManager) InsertBucket(settings *BucketSettings) error

+ func (cm *ClusterManager) RemoveBucket(name string) error

+ func (cm *ClusterManager) UpdateBucket(settings *BucketSettings) error

+ type ConsistencyMode int

+ type CounterOp struct

+ Cas Cas

+ Delta int64

+ Err error

+ Expiry uint32

+ Initial int64

+ Key string

+ Value uint64

+ type DefaultTranscoder struct

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

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

+ type DesignDocument struct

+ Name string

+ SpatialViews map[string]View

+ Views map[string]View

+ type DocumentFragment struct

+ func (frag *DocumentFragment) Cas() Cas

+ func (frag *DocumentFragment) Content(path string, valuePtr interface{}) error

+ func (frag *DocumentFragment) ContentByIndex(idx int, valuePtr interface{}) error

+ func (frag *DocumentFragment) Exists(path string) bool

+ func (frag *DocumentFragment) MutationToken() MutationToken

+ type GetAndTouchOp struct

+ Cas Cas

+ Err error

+ Expiry uint32

+ Key string

+ Value interface{}

+ type GetOp struct

+ Cas Cas

+ Err error

+ Key string

+ Value interface{}

+ type IndexInfo struct

+ IndexKey []string

+ IsPrimary bool

+ Keyspace string

+ Name string

+ Namespace string

+ State string

+ Type IndexType

+ type IndexType string

+ type InsertOp struct

+ Cas Cas

+ Err error

+ Expiry uint32

+ Key string

+ Value interface{}

+ type LookupInBuilder struct

+ func (set *LookupInBuilder) Execute() (*DocumentFragment, error)

+ func (set *LookupInBuilder) Exists(path string) *LookupInBuilder

+ func (set *LookupInBuilder) Get(path string) *LookupInBuilder

+ type MutateInBuilder struct

+ func (set *MutateInBuilder) ArrayAddUnique(path string, value interface{}, createParents bool) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayAppend(path string, value interface{}, createParents bool) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayAppendMulti(path string, values interface{}, createParents bool) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayInsert(path string, value interface{}) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayInsertMulti(path string, values interface{}) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayPrepend(path string, value interface{}, createParents bool) *MutateInBuilder

+ func (set *MutateInBuilder) ArrayPrependMulti(path string, values interface{}, createParents bool) *MutateInBuilder

+ func (set *MutateInBuilder) Counter(path string, delta int64, createParents bool) *MutateInBuilder

+ func (set *MutateInBuilder) Execute() (*DocumentFragment, error)

+ func (set *MutateInBuilder) Insert(path string, value interface{}, createParents bool) *MutateInBuilder

+ func (set *MutateInBuilder) Remove(path string) *MutateInBuilder

+ func (set *MutateInBuilder) Replace(path string, value interface{}) *MutateInBuilder

+ func (set *MutateInBuilder) Upsert(path string, value interface{}, createParents bool) *MutateInBuilder

+ 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

+ type N1qlQuery struct

+ func NewN1qlQuery(statement string) *N1qlQuery

+ func (nq *N1qlQuery) AdHoc(adhoc bool) *N1qlQuery

+ func (nq *N1qlQuery) Consistency(stale ConsistencyMode) *N1qlQuery

+ func (nq *N1qlQuery) ConsistentWith(state *MutationState) *N1qlQuery

+ func (nq *N1qlQuery) Custom(name string, value interface{}) *N1qlQuery

+ func (nq *N1qlQuery) Timeout(timeout time.Duration) *N1qlQuery

+ type PrependOp struct

+ Cas Cas

+ Err error

+ Key string

+ Value string

+ type QueryResultMetrics struct

+ ElapsedTime time.Duration

+ ErrorCount uint

+ ExecutionTime time.Duration

+ MutationCount uint

+ ResultCount uint

+ ResultSize uint

+ SortCount uint

+ WarningCount uint

+ type QueryResults interface

+ ClientContextId func() string

+ Close func() error

+ Metrics func() QueryResultMetrics

+ Next func(valuePtr interface{}) bool

+ NextBytes func() []byte

+ One func(valuePtr interface{}) error

+ RequestId func() string

+ type RemoveOp struct

+ Cas Cas

+ Err error

+ Key string

+ type ReplaceOp struct

+ Cas Cas

+ Err error

+ Expiry uint32

+ Key string

+ Value interface{}

+ type SearchHighlightStyle string

+ type SearchQuery struct

+ func NewSearchQuery(indexName string, query interface{}) *SearchQuery

+ func (sq *SearchQuery) AddFacet(name string, facet interface{}) *SearchQuery

+ func (sq *SearchQuery) Consistency(stale ConsistencyMode) *SearchQuery

+ func (sq *SearchQuery) ConsistentWith(state *MutationState) *SearchQuery

+ func (sq *SearchQuery) Explain(value bool) *SearchQuery

+ func (sq *SearchQuery) Fields(fields ...string) *SearchQuery

+ func (sq *SearchQuery) Highlight(style SearchHighlightStyle, fields ...string) *SearchQuery

+ func (sq *SearchQuery) Limit(value int) *SearchQuery

+ func (sq *SearchQuery) Skip(value int) *SearchQuery

+ func (sq *SearchQuery) Sort(fields ...string) *SearchQuery

+ func (sq *SearchQuery) Timeout(value time.Duration) *SearchQuery

+ type SearchResultDateFacet struct

+ Count int

+ Max string

+ Min string

+ Name string

+ type SearchResultFacet struct

+ DateRanges []SearchResultDateFacet

+ Field string

+ Missing int

+ NumericRanges []SearchResultNumericFacet

+ Other int

+ Terms []SearchResultTermFacet

+ Total int

+ type SearchResultHit struct

+ Explanation map[string]interface{}

+ Fields map[string]string

+ Fragments map[string][]string

+ Id string

+ Index string

+ Locations map[string]map[string][]SearchResultLocation

+ Score float64

+ type SearchResultLocation struct

+ ArrayPositions []uint

+ End int

+ Position int

+ Start int

+ type SearchResultNumericFacet struct

+ Count int

+ Max float64

+ Min float64

+ Name string

+ type SearchResultStatus struct

+ Failed int

+ Successful int

+ Total int

+ type SearchResultTermFacet struct

+ Count int

+ Term string

+ type SearchResults interface

+ Errors func() []string

+ Facets func() map[string]SearchResultFacet

+ Hits func() []SearchResultHit

+ MaxScore func() float64

+ Status func() SearchResultStatus

+ Took func() time.Duration

+ TotalHits func() int

+ type ServerStats map[string]map[string]string

+ type SortOrder int

+ type SpatialQuery struct

+ func NewSpatialQuery(ddoc, name string) *SpatialQuery

+ func (vq *SpatialQuery) Bbox(bounds []float64) *SpatialQuery

+ func (vq *SpatialQuery) Custom(name, value string) *SpatialQuery

+ func (vq *SpatialQuery) Development(val bool) *SpatialQuery

+ func (vq *SpatialQuery) Limit(num uint) *SpatialQuery

+ func (vq *SpatialQuery) Skip(num uint) *SpatialQuery

+ func (vq *SpatialQuery) Stale(stale StaleMode) *SpatialQuery

+ type StaleMode int

+ type StreamingBucket struct

+ func (b *StreamingBucket) IoRouter() *gocbcore.Agent

+ type TouchOp struct

+ Cas Cas

+ Err error

+ Expiry uint32

+ Key string

+ type Transcoder interface

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

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

+ type UpsertOp struct

+ Cas Cas

+ Err error

+ Expiry uint32

+ Key string

+ Value interface{}

+ type View struct

+ Map string

+ Reduce string

+ type ViewQuery struct

+ func NewViewQuery(ddoc, name string) *ViewQuery

+ func (vq *ViewQuery) Custom(name, value string) *ViewQuery

+ func (vq *ViewQuery) Development(val bool) *ViewQuery

+ func (vq *ViewQuery) Group(useGrouping bool) *ViewQuery

+ func (vq *ViewQuery) GroupLevel(groupLevel uint) *ViewQuery

+ func (vq *ViewQuery) IdRange(start, end string) *ViewQuery

+ func (vq *ViewQuery) Key(key interface{}) *ViewQuery

+ func (vq *ViewQuery) Keys(keys []interface{}) *ViewQuery

+ func (vq *ViewQuery) Limit(num uint) *ViewQuery

+ func (vq *ViewQuery) Order(order SortOrder) *ViewQuery

+ func (vq *ViewQuery) Range(start, end interface{}, inclusiveEnd bool) *ViewQuery

+ func (vq *ViewQuery) Reduce(reduce bool) *ViewQuery

+ func (vq *ViewQuery) Skip(num uint) *ViewQuery

+ func (vq *ViewQuery) Stale(stale StaleMode) *ViewQuery

+ type ViewResults interface

+ Close func() error

+ Next func(valuePtr interface{}) bool

+ NextBytes func() []byte

+ One func(valuePtr interface{}) error