Class CouchbaseSource<TOutput>
A data flow source for Couchbase
Inherited Members
Namespace: ETLBox.Couchbase
Assembly: ETLBox.Couchbase.dll
Syntax
public class CouchbaseSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowLogging, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask
Type Parameters
| Name | Description |
|---|---|
| TOutput | Type of outgoing data. |
Constructors
CouchbaseSource()
Declaration
public CouchbaseSource()
Properties
ClusterOptions
If you provide ClusterOptions (or a connection string), this component will create a new Cluster object to connect with Couchbase. If you already have a cluster object instantiated in your application, use CouchbaseCluster instead to pass it directly to the component. Instead or additional to a ClustOptions you can also set the ConnectionString.
Declaration
public ClusterOptions ClusterOptions { get; set; }
Property Value
| Type | Description |
|---|---|
| ClusterOptions |
ConnectionString
If you provide a connection string (or cluster options), this component will create a new Cluster object to connect with Couchbase. If you already have a cluster object instantiated in your application, use CouchbaseCluster instead to pass it directly to the component. Instead or additional to a connection string you can also set the ClusterOptions.
Declaration
public string ConnectionString { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
CouchbaseCluster
An existing couchbase Cluster that holds a couchbase connection.
Declaration
public ICluster CouchbaseCluster { get; set; }
Property Value
| Type | Description |
|---|---|
| ICluster |
N1QLStatement
The N1QL statement used to retrieve data from your Couchbase DB. Objects will be deserialized from json.
Declaration
public string N1QLStatement { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
Options
Additional query options when retrieving data with the N1QLStatement
Declaration
public QueryOptions Options { get; set; }
Property Value
| Type | Description |
|---|---|
| QueryOptions |
Methods
CheckParameter()
Declaration
protected override void CheckParameter()
Overrides
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)
Parameters
| Type | Name | Description |
|---|---|---|
| Exception | e |
Overrides
CleanUpOnSuccess()
Declaration
protected override void CleanUpOnSuccess()
Overrides
InitCheckedParameter()
Declaration
protected override void InitCheckedParameter()
Overrides
OnExecutionDoAsyncWork()
Declaration
protected override void OnExecutionDoAsyncWork()
Overrides
Reset()
Declaration
protected override void Reset()