Versions in this module Expand all Collapse all v0 v0.2.0 Dec 13, 2019 Changes in this version + const ChangesDelete + const ChangesError + const ChangesHeartbeat + const ChangesInsert + const ChangesTerminated + const ChangesUpdate + const VERSION + var LogFunc = log.Printf + func Endpoint(base url.URL, pathStr string, params url.Values) (string, error) + type AllDBsQueryBuilder interface + Build func() *allDBsQuery + EndKey func(string) AllDBsQueryBuilder + InclusiveEnd func() AllDBsQueryBuilder + Limit func(int) AllDBsQueryBuilder + Skip func(int) AllDBsQueryBuilder + StartKey func(string) AllDBsQueryBuilder + func NewAllDBsQuery() AllDBsQueryBuilder + type AllDocsQueryBuilder interface + Build func() *allDocsQuery + Conflicts func() AllDocsQueryBuilder + DeletedConflicts func() AllDocsQueryBuilder + Descending func() AllDocsQueryBuilder + EndKey func(string) AllDocsQueryBuilder + IncludeDocs func() AllDocsQueryBuilder + InclusiveEnd func() AllDocsQueryBuilder + Key func(string) AllDocsQueryBuilder + Keys func([]string) AllDocsQueryBuilder + Limit func(int) AllDocsQueryBuilder + Meta func() AllDocsQueryBuilder + R func(int) AllDocsQueryBuilder + RevsInfo func() AllDocsQueryBuilder + Skip func(int) AllDocsQueryBuilder + StartKey func(string) AllDocsQueryBuilder + func NewAllDocsQuery() AllDocsQueryBuilder + type AllRow struct + Doc interface{} + ID string + Value AllRowValue + type AllRowValue struct + Rev string + type BulkDocsRequest struct + Docs []interface{} + NewEdits bool + type BulkDocsResponse struct + Error string + ID string + Reason string + Rev string + type BulkJob struct + Error error + Response *BulkDocsResponse + func (j *BulkJob) Wait() + type BulkJobI interface + Wait func() + type Change struct + Deleted bool + Doc map[string]interface{} + ID string + Rev string + Seq string + type ChangeEvent struct + Doc map[string]interface{} + Err error + EventType int + Meta *DocumentMeta + Seq string + type ChangeRow struct + Changes []ChangeRowChanges + Deleted bool + Doc map[string]interface{} + ID string + Seq string + func (c *ChangeRow) UnmarshalJSON(data []byte) error + type ChangeRowChanges struct + Rev string + type ChangesQueryBuilder interface + Build func() *changesQuery + Conflicts func() ChangesQueryBuilder + Descending func() ChangesQueryBuilder + DocIDs func([]string) ChangesQueryBuilder + Feed func(string) ChangesQueryBuilder + Filter func(string) ChangesQueryBuilder + Heartbeat func(int) ChangesQueryBuilder + IncludeDocs func() ChangesQueryBuilder + Limit func(int) ChangesQueryBuilder + SeqInterval func(int) ChangesQueryBuilder + Since func(string) ChangesQueryBuilder + Style func(string) ChangesQueryBuilder + Timeout func(int) ChangesQueryBuilder + func NewChangesQuery() ChangesQueryBuilder + type CouchClient struct + func CreateClient(username, password, rootStrURL string, concurrency int) (*CouchClient, error) + func CreateClientWithRetry(username, password, rootStrURL string, ...) (*CouchClient, error) + func (c *CouchClient) AllDBs(args *allDBsQuery) (*[]string, error) + func (c *CouchClient) Delete(databaseName string) error + func (c *CouchClient) Execute(job *Job) + func (c *CouchClient) Exists(databaseName string) (bool, error) + func (c *CouchClient) Get(databaseName string) (*Database, error) + func (c *CouchClient) GetOrCreate(databaseName string) (*Database, error) + func (c *CouchClient) LogIn() error + func (c *CouchClient) LogOut() + func (c *CouchClient) Ping() (err error) + func (c *CouchClient) Stop() + type CouchError struct + Err string + Reason string + StatusCode int + func (e *CouchError) Error() string + type CreateIndexBuilder interface + Build func() *createIndex + DDoc func(string) CreateIndexBuilder + Fields func([]string) CreateIndexBuilder + Name func(string) CreateIndexBuilder + Partitioned func(bool) CreateIndexBuilder + Type func(IndexType) CreateIndexBuilder + func NewCreateIndex() CreateIndexBuilder + type CreateIndexResponse struct + Result string + type CredentialsExpiredResponse struct + Error string + type Database struct + Name string + URL *url.URL + func (d *Database) All(args *allDocsQuery) (<-chan *AllRow, error) + func (d *Database) Bulk(batchSize int, batchMaxBytes int, flushSecs int) *Uploader + func (d *Database) Changes(args *changesQuery) (<-chan *Change, error) + func (d *Database) Delete(documentID, rev string) error + func (d *Database) Find(findArgs *find) (*FindResponse, error) + func (d *Database) Get(documentID string, args *getQuery, target interface{}) error + func (d *Database) Index(createIndexArgs *createIndex) (*CreateIndexResponse, error) + func (d *Database) Info() (*Info, error) + func (d *Database) Set(document interface{}) (*DocumentMeta, error) + type DocumentMeta struct + ID string + Rev string + type FindBuilder interface + AddSort func(interface{}) FindBuilder + Bookmark func(string) FindBuilder + Build func() *find + Conflicts func(bool) FindBuilder + ExecutionStats func(bool) FindBuilder + Fields func([]string) FindBuilder + Limit func(int) FindBuilder + R func(int) FindBuilder + SetSelector func(string, interface{}) FindBuilder + Skip func(int) FindBuilder + UseIndex func(string) FindBuilder + func NewFind() FindBuilder + type FindResponse struct + Bookmark string + Docs []interface{} + ExecutionStats executionStatus + type Follower struct + func NewFollower(database *Database, interval int) *Follower + func (f *Follower) Close() + func (f *Follower) Follow() (<-chan *ChangeEvent, error) + type GetQueryBuilder interface + AttEncodingInfo func() GetQueryBuilder + Attachments func() GetQueryBuilder + AttsSince func([]string) GetQueryBuilder + Build func() *getQuery + Conflicts func() GetQueryBuilder + DeletedConflicts func() GetQueryBuilder + Latest func() GetQueryBuilder + LocalSeq func() GetQueryBuilder + Meta func() GetQueryBuilder + OpenRevs func([]string) GetQueryBuilder + Rev func(string) GetQueryBuilder + Revs func() GetQueryBuilder + RevsInfo func() GetQueryBuilder + func NewGetQuery() GetQueryBuilder + type IndexType string + const IndexTypeJSON + const IndexTypeText + type Info struct + DataSize int + DiskSize int + DocCount int + DocDelCount int + IsCompactRunning bool + UpdateSeq string + type Job struct + func CreateJob(request *http.Request) *Job + func UploadBulkDocs(bulkDocs *BulkDocsRequest, database *Database) (result *Job, err error) + func (j *Job) Close() + func (j *Job) Response() *http.Response + func (j *Job) Wait() + type QueryBuilder interface + GetQuery func() (url.Values, error) + type Uploader struct + NewEdits bool + func (u *Uploader) AsyncFlush() + func (u *Uploader) BulkUploadSimple(docs []interface{}) ([]BulkDocsResponse, error) + func (u *Uploader) FireAndForget(doc interface{}) + func (u *Uploader) Flush() + func (u *Uploader) Stop() + func (u *Uploader) Upload(doc interface{}) *BulkJob + func (u *Uploader) UploadNow(doc interface{}) *BulkJob