cloudant

package module

Go to main page

Versions in this module

v0

v0.3.6

Dec 31, 2021

Changes in this version

+ const SLASHPLACEHOLDER

v0.3.5

Apr 26, 2021

Changes in this version

type ViewQuery

+ func (q *ViewQuery) DoNotReduce() *ViewQuery

v0.3.4

Oct 5, 2020

Changes in this version

type Database

+ func (d *Database) Index(designName, indexName string, q *IndexQuery) (<-chan []byte, error)

+ func (d *Database) IndexRaw(designName, indexName string, q *IndexQuery) ([]byte, error)

+ type IndexQuery struct

+ URLValues url.Values

+ func NewIndexQuery() *IndexQuery

+ func (q *IndexQuery) Bookmark(bookmark string) *IndexQuery

+ func (q *IndexQuery) IncludeDocs() *IndexQuery

+ func (q *IndexQuery) IncludeFields(fields []string) *IndexQuery

+ func (q *IndexQuery) Limit(lim int) *IndexQuery

+ func (q *IndexQuery) Query(query string) *IndexQuery

+ func (q *IndexQuery) Stale() *IndexQuery

+ type IndexRow struct

+ Fields interface{}

+ ID string

v0.3.3

Apr 28, 2020

v0.3.2

Apr 28, 2020

Changes in this version

type Database

+ func (d *Database) BulkEscaped(batchSize int, batchMaxBytes int, flushSecs int) *Uploader

v0.3.1

Apr 18, 2020

v0.3.0

Dec 28, 2019

Changes in this version

type ChangesQuery

+ DocIDValues []string

+ URLValues url.Values

+ type Client struct

+ func NewClient(username, password, rootStrURL string, options ...ClientOption) (*Client, error)

+ func (c *Client) Destroy(databaseName string) error

+ func (c *Client) Execute(job *Job)

+ func (c *Client) Exists(databaseName string) (bool, error)

+ func (c *Client) Info(databaseName string) (*Info, error)

+ func (c *Client) List(q *DBsQuery) (*[]string, error)

+ func (c *Client) LogIn() error

+ func (c *Client) LogOut()

+ func (c *Client) Ping() (err error)

+ func (c *Client) Stop()

+ func (c *Client) Use(databaseName string) (*Database, error)

+ func (c *Client) UseOrCreate(databaseName string) (*Database, error)

+ type ClientOption func(*Client)

+ func ClientConcurrency(workerCount int) ClientOption

+ func ClientHTTPClient(httpClient *http.Client) ClientOption

+ func ClientRetryCountMax(retryCountMax int) ClientOption

+ func ClientRetryDelayMax(retryDelayMax int) ClientOption

+ func ClientRetryDelayMin(retryDelayMin int) ClientOption

type DBsQuery

+ URLValues url.Values

type DocQuery

+ URLValues url.Values

+ func (q *DocQuery) AttsSince(since []string) *DocQuery

+ func (q *DocQuery) OpenRevs(revs []string) *DocQuery

type ViewQuery

+ KeyValues []string

+ URLValues url.Values

v0.2.0

Dec 23, 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)

+ func NoParams() url.Values

+ func UnescapedHTMLJSONMarshal(t interface{}) ([]byte, error)

+ 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 ChangesQuery struct

+ Values url.Values

+ func NewChangesQuery() *ChangesQuery

+ func (q *ChangesQuery) Conflicts() *ChangesQuery

+ func (q *ChangesQuery) Descending() *ChangesQuery

+ func (q *ChangesQuery) DocIDs(docIDs []string) *ChangesQuery

+ func (q *ChangesQuery) Feed(feed string) *ChangesQuery

+ func (q *ChangesQuery) Filter(filter string) *ChangesQuery

+ func (q *ChangesQuery) Heartbeat(heartbeat int) *ChangesQuery

+ func (q *ChangesQuery) IncludeDocs() *ChangesQuery

+ func (q *ChangesQuery) Limit(lim int) *ChangesQuery

+ func (q *ChangesQuery) SeqInterval(interval int) *ChangesQuery

+ func (q *ChangesQuery) Since(since string) *ChangesQuery

+ func (q *ChangesQuery) Style(style string) *ChangesQuery

+ func (q *ChangesQuery) Timeout(timeout int) *ChangesQuery

+ type CouchClient struct

+ func CreateClient(username, password, rootStrURL string, concurrency int) (*CouchClient, error)

+ func CreateClientWithRetry(username, password, rootStrURL string, ...) (*CouchClient, error)

+ func (c *CouchClient) Destroy(databaseName string) error

+ func (c *CouchClient) Execute(job *Job)

+ func (c *CouchClient) Exists(databaseName string) (bool, error)

+ func (c *CouchClient) Info(databaseName string) (*Info, error)

+ func (c *CouchClient) List(params url.Values) (*[]string, error)

+ func (c *CouchClient) LogIn() error

+ func (c *CouchClient) LogOut()

+ func (c *CouchClient) Ping() (err error)

+ func (c *CouchClient) Stop()

+ func (c *CouchClient) Use(databaseName string) (*Database, error)

+ func (c *CouchClient) UseOrCreate(databaseName string) (*Database, error)

+ type CouchError struct

+ Err string

+ Reason string

+ StatusCode int

+ func (e *CouchError) Error() string

+ type CredentialsExpiredResponse struct

+ Error string

+ type DBsQuery struct

+ Values url.Values

+ func NewDBsQuery() *DBsQuery

+ func (q *DBsQuery) Descending() *DBsQuery

+ func (q *DBsQuery) EndKey(endKey string) *DBsQuery

+ func (q *DBsQuery) InclusiveEnd() *DBsQuery

+ func (q *DBsQuery) Limit(lim int) *DBsQuery

+ func (q *DBsQuery) Skip(skip int) *DBsQuery

+ func (q *DBsQuery) StartKey(startKey string) *DBsQuery

+ type Database struct

+ Name string

+ URL *url.URL

+ func (d *Database) Bulk(batchSize int, batchMaxBytes int, flushSecs int) *Uploader

+ func (d *Database) Changes(params url.Values) (<-chan *Change, error)

+ func (d *Database) Destroy(documentID, rev string) error

+ func (d *Database) Get(documentID string, params url.Values, target interface{}) error

+ func (d *Database) Insert(document interface{}) (*DocumentMeta, error)

+ func (d *Database) InsertEscaped(document interface{}) (*DocumentMeta, error)

+ func (d *Database) InsertRaw(jsonDocument []byte) (*DocumentMeta, error)

+ func (d *Database) List(params url.Values) (<-chan *AllRow, error)

+ func (d *Database) NewFollower(interval int) *Follower

+ func (d *Database) View(designName, viewName string, params url.Values, target interface{}) error

+ func (d *Database) ViewRaw(designName, viewName string, params url.Values) ([]byte, error)

+ type DocQuery struct

+ Values url.Values

+ func NewDocQuery() *DocQuery

+ func (q *DocQuery) AttEncodingInfo() *DocQuery

+ func (q *DocQuery) Attachments() *DocQuery

+ func (q *DocQuery) Conflicts() *DocQuery

+ func (q *DocQuery) DeletedConflicts() *DocQuery

+ func (q *DocQuery) Latest() *DocQuery

+ func (q *DocQuery) LocalSeq() *DocQuery

+ func (q *DocQuery) Meta() *DocQuery

+ func (q *DocQuery) Rev(rev string) *DocQuery

+ func (q *DocQuery) Revs() *DocQuery

+ func (q *DocQuery) RevsInfo() *DocQuery

+ func (q *DocQuery) Skip(skip int) *DocQuery

+ type DocumentMeta struct

+ ID string

+ Rev string

+ type Follower struct

+ func (f *Follower) Close()

+ func (f *Follower) Follow() (<-chan *ChangeEvent, error)

+ type Info struct

+ DBName string

+ DiskFromatVersion int

+ DiskSize int

+ DocCount int

+ DocDelCount int

+ IsCompactRunning bool

+ PurgeSeq int

+ Sizes Sizes

+ 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 Sizes struct

+ Active int

+ External int

+ File int

+ 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

+ type View struct

+ Error string

+ Rows []ViewRow

+ type ViewQuery struct

+ Values url.Values

+ func NewViewQuery() *ViewQuery

+ func (q *ViewQuery) AttsSince(since []string) *ViewQuery

+ func (q *ViewQuery) Conflicts() *ViewQuery

+ func (q *ViewQuery) DeletedConflicts() *ViewQuery

+ func (q *ViewQuery) Descending() *ViewQuery

+ func (q *ViewQuery) DoNotUpdate() *ViewQuery

+ func (q *ViewQuery) EndKey(endKey string) *ViewQuery

+ func (q *ViewQuery) EndKeyDocID(endKeyDocID string) *ViewQuery

+ func (q *ViewQuery) Group() *ViewQuery

+ func (q *ViewQuery) GroupLevel(groupLevel int) *ViewQuery

+ func (q *ViewQuery) IncludeDocs() *ViewQuery

+ func (q *ViewQuery) InclusiveEnd() *ViewQuery

+ func (q *ViewQuery) Key(key string) *ViewQuery

+ func (q *ViewQuery) Keys(keys []string) *ViewQuery

+ func (q *ViewQuery) Limit(lim int) *ViewQuery

+ func (q *ViewQuery) Meta() *ViewQuery

+ func (q *ViewQuery) OpenRevs(revs []string) *ViewQuery

+ func (q *ViewQuery) R(r int) *ViewQuery

+ func (q *ViewQuery) Reduce() *ViewQuery

+ func (q *ViewQuery) RevsInfo() *ViewQuery

+ func (q *ViewQuery) Skip(skip int) *ViewQuery

+ func (q *ViewQuery) Stable() *ViewQuery

+ func (q *ViewQuery) Stale() *ViewQuery

+ func (q *ViewQuery) StaleUpdateAfter() *ViewQuery

+ func (q *ViewQuery) StartKey(startKey string) *ViewQuery

+ func (q *ViewQuery) StartKeyDocID(startKeyDocID string) *ViewQuery

+ func (q *ViewQuery) UpdateLazy() *ViewQuery

+ type ViewRow struct

+ Doc interface{}

+ ID string

+ Key string

+ Value string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL