Documentation
¶
Index ¶
- func ComputeHash(id []byte, algorithm string) (string, error)
- func NewCouchbase(db repo.IRepo) common.IDestination
- type Couchbase
- func (c *Couchbase) Complete() (err error)
- func (c *Couchbase) CreateIndexes(indexes []common.Index) error
- func (c *Couchbase) Init(cbOpts *option.Options, documentKey common.ICBDocumentKey) error
- func (c *Couchbase) ProcessData(data map[string]interface{}) error
- func (c *Couchbase) UpsertData() error
- type DocKey
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCouchbase ¶
func NewCouchbase(db repo.IRepo) common.IDestination
Types ¶
type Couchbase ¶
type Couchbase struct {
HashDocumentKey string
// contains filtered or unexported fields
}
func (*Couchbase) ProcessData ¶
func (*Couchbase) UpsertData ¶
type DocKey ¶
type DocKey struct {
Value string
Kind common.DocumentKind // string | field | UUID
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.