couchbase

Documentation

Index

• Variables
• type Couchbase
  • func (d *Couchbase) Cleanup() error
  • func (d *Couchbase) ClearWork() error
  • func (d *Couchbase) GetWork() (io.Reader, error)
  • func (d *Couchbase) HandleFailure() error
  • func (d *Couchbase) Init() error
  • func (d *Couchbase) LoadEnv(prefix string) error
  • func (d *Couchbase) LoadFlags() error
• type CouchbaseDoc
• type CouchbaseOp

Variables

var (
	CouchbaseOpRM    = CouchbaseOp("rm")
	CouchbaseOpMV    = CouchbaseOp("mv")
	CouchbaseOpSet   = CouchbaseOp("set")
	CouchbaseOpMerge = CouchbaseOp("merge")
)

Types

type Couchbase

type Couchbase struct {
	Client        *gocb.Cluster
	Address       string
	User          *string
	Password      *string
	BucketName    *string
	Scope         *string
	Collection    *string
	ID            *string
	RetrieveQuery *schema.SqlQuery
	Clear         *CouchbaseDoc
	Fail          *CouchbaseDoc
	// TLS
	EnableTLS   *bool
	TLSInsecure *bool
	TLSCert     *string
	TLSKey      *string
	TLSCA       *string
	// contains filtered or unexported fields
}

func (*Couchbase) Cleanup

func (d *Couchbase) Cleanup() error

func (*Couchbase) ClearWork

func (d *Couchbase) ClearWork() error

func (*Couchbase) GetWork

func (d *Couchbase) GetWork() (io.Reader, error)

func (*Couchbase) HandleFailure

func (d *Couchbase) HandleFailure() error

func (*Couchbase) Init

func (d *Couchbase) Init() error

func (*Couchbase) LoadEnv

func (d *Couchbase) LoadEnv(prefix string) error

func (*Couchbase) LoadFlags

func (d *Couchbase) LoadFlags() error

type CouchbaseDoc

type CouchbaseDoc struct {
	Op         CouchbaseOp    `json:"op"`
	Doc        map[string]any `json:"doc"`
	Bucket     string         `json:"bucket"`
	Scope      string         `json:"scope"`
	Collection string         `json:"collection"`
	ID         string         `json:"id"`
}

type CouchbaseOp

type CouchbaseOp string