couchbase

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

Functions

func ComputeHash

func ComputeHash(id []byte, algorithm string) (string, error)

func NewCouchbase

func NewCouchbase(db repo.IRepo) common.IDestination

Types

type Couchbase

type Couchbase struct {
	HashDocumentKey string
	// contains filtered or unexported fields
}

func (*Couchbase) Complete

func (c *Couchbase) Complete() (err error)

func (*Couchbase) CreateIndexes

func (c *Couchbase) CreateIndexes(indexes []common.Index) error

func (*Couchbase) Init

func (c *Couchbase) Init(cbOpts *option.Options, documentKey common.ICBDocumentKey) error

func (*Couchbase) ProcessData

func (c *Couchbase) ProcessData(data map[string]interface{}) error

func (*Couchbase) UpsertData

func (c *Couchbase) UpsertData() error

type DocKey

type DocKey struct {
	Value string
	Kind  common.DocumentKind // string | field | UUID
}