# README
cbdatasource
golang library to stream data from a Couchbase cluster
The cbdatasource package is implemented using Couchbase DCP protocol and has auto-reconnecting and auto-restarting goroutines underneath the hood to provide a simple, high-level cluster-wide abstraction. By using cbdatasource, your application does not need to worry about connections or reconnections to individual server nodes or cluster topology changes, rebalance & failovers. The API starting point is NewBucketDataSource().
LICENSE: Apache 2.0
Status & Links
# Packages
No description provided by the author
# Functions
ConnectBucket is the default function used by BucketDataSource to connect to a Couchbase cluster to retrieve Bucket information.
ExponentialBackoffLoop invokes f() in a loop, sleeping an exponentially growing number of milliseconds in between invocations if needed.
NewBucketDataSource is the main starting point for using the cbdatasource API.
ParseFailOverLog parses a byte array to an array of [vbucketUUID, seqNum] pairs.
No description provided by the author
UPROpen starts a UPR_OPEN stream on a memcached client connection.
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
DefaultBucketDataSourceOptions defines the default options that will be used if nil is provided to NewBucketDataSource().
No description provided by the author
# Structs
AllServerURLsConnectBucketError is the error type passed to Receiver.OnError() when the BucketDataSource failed to connect to all the serverURL's provided as a parameter to NewBucketDataSource().
AuthFailError is the error type passed to Receiver.OnError() when there is an auth request error to the Couchbase cluster or server node.
BucketDataSourceOptions allows the application to provide configuration settings to NewBucketDataSource().
BucketDataSourceStats is filled by the BucketDataSource.Stats() method.
No description provided by the author
VBucketMetaData is an internal struct that is exposed to enable json marshaling.
No description provided by the author
# Interfaces
A Bucket interface defines the set of methods that cbdatasource needs from an abstract couchbase.Bucket.
BucketDataSource is the main control interface returned by NewBucketDataSource().
A Receiver interface is implemented by the application, or the receiver of data.
A ReceiverEx interface is an advanced Receiver interface that's optionally implemented by the application, or the receiver of data.