Versions in this module Expand all Collapse all v0 v0.1.1 Oct 27, 2021 v0.1.0 Apr 20, 2021 Changes in this version + const ABS_MAX_RETRIES + const ABS_MIN_RETRIES + const AddOnly + const Append + const DEFAULT_WINDOW_SIZE + const DISCONNECT_PERIOD + const HTTP_MAX_RETRY + const Indexable + const MAX_RETRY_COUNT + const OBSERVE + const ObserveNone + const ObserveReplicateFour + const ObserveReplicateOne + const ObserveReplicateThree + const ObserveReplicateTwo + const PERSIST + const Persist + const PersistFour + const PersistMaster + const PersistNone + const PersistOne + const PersistThree + const PersistTwo + const Raw + const START_NODE_ID + const StatCount + const StatSize + const UpdateCancel + var AsynchronousCloser = false + var ClientOpCallback func(opname, k string, start time.Time, err error) + var ClientTimeOut = 10 * time.Second + var ConnCloserInterval = time.Second * 30 + var ConnPoolAvailWaitTime = time.Millisecond + var ConnPoolCallback func(host string, source string, start time.Time, err error) + var ConnPoolTimeout = time.Hour * 24 * 30 + var DefaultDialTimeout = time.Duration(0) + var DefaultTimeout = time.Duration(0) + var EnableCollections = false + var EnableDataType = false + var EnableMutationToken = false + var EnableXattr = false + var ErrKeyExists = errors.New("key exists") + var ErrOverwritten = errors.New("overwritten") + var ErrTimeout = errors.New("timeout") + var HTTPClient = &http.Client + var HTTPClientForStreaming = &http.Client + var HTTPTransport = &http.Transport + var MaxBackOffRetries = 25 + var MaxBulkRetries = 5000 + var MaxIdleConnsPerHost = 256 + var OPJobChan = make(chan *ObservePersistJob, 1024) + var OPJobDone = make(chan bool) + var ObservePersistPool = NewPool(1024) + var PoolOverflow = 16 + var PoolSize = 64 + var SlowServerCallWarningThreshold time.Duration + var TCPKeepalive = false + var TCPKeepaliveInterval = 30 * 60 + var TimeoutError = errors.New("timeout waiting to build connection") + var ViewCallback func(ddoc, name string, start time.Time, err error) + func AlreadyExistsError(err error) bool + func CleanupHost(h, commonSuffix string) string + func ClientConfigForX509(certFile, keyFile, rootFile string) (*tls.Config, error) + func DisableOverflowConnections() + func DropSystemBucket(c *Client, name string) error + func EnableAsynchronousCloser(closer bool) + func FindCommonSuffix(input []string) string + func InitBulkGet() + func IsKeyEExistsError(err error) bool + func IsKeyNoEntError(err error) bool + func IsReadTimeOutError(err error) bool + func IsRefreshRequired(err error) bool + func IsUnknownCollection(err error) bool + func MapKVtoSSL(hostport string, ps *PoolServices) (string, bool, error) + func MapKVtoSSLExt(hostport string, ps *PoolServices, force bool) (string, bool, error) + func ParseURL(urlStr string) (result *url.URL, err error) + func SetCertFile(cert string) + func SetConnectionPoolParams(size, overflow int) + func SetKeyFile(cert string) + func SetRootFile(cert string) + func SetSkipVerify(skip bool) + func SetTcpKeepalive(enabled bool, interval int) + func SetViewUpdateParams(baseU string, params map[string]interface{}) (viewOpts map[string]interface{}, err error) + type AuditSpec struct + AuditdEnabled bool + Disabled []uint32 + DisabledUsers []AuditUser + LogPath string + RotateInterval int64 + RotateSize int64 + Uid string + type AuditUser struct + Domain string + Name string + type AuthHandler interface + GetCredentials func() (string, string, string) + type AuthWithSaslHandler interface + GetSaslCredentials func() (string, string) + type Bucket struct + BasicStats map[string]interface{} + Capabilities []string + CapabilitiesVersion string + CollectionsManifestUid string + ConflictResolutionType string + Controllers map[string]interface{} + DDocs struct{ ... } + LocalRandomKeyURI string + Name string + NodeLocator string + NodesJSON []Node + Quota map[string]float64 + Replicas int + StreamingURI string + Type string + URI string + UUID string + VBSMJson VBucketServerMap + func ConnectWithAuthAndGetBucket(endpoint, poolname, bucketname string, ah AuthHandler) (*Bucket, error) + func GetBucket(endpoint, poolname, bucketname string) (*Bucket, error) + func GetSystemBucket(c *Client, p *Pool, name string) (*Bucket, error) + func (b *Bucket) Add(k string, exp int, v interface{}, context ...*memcached.ClientContext) (added bool, err error) + func (b *Bucket) AddRaw(k string, exp int, v []byte, context ...*memcached.ClientContext) (added bool, err error) + func (b *Bucket) AddRawWithMT(k string, exp int, v []byte, context ...*memcached.ClientContext) (added bool, mt *MutationToken, err error) + func (b *Bucket) AddWithCAS(k string, exp int, v interface{}, context ...*memcached.ClientContext) (bool, uint64, error) + func (b *Bucket) AddWithMT(k string, exp int, v interface{}, context ...*memcached.ClientContext) (added bool, mt *MutationToken, err error) + func (b *Bucket) Append(k string, data []byte, context ...*memcached.ClientContext) error + func (b *Bucket) Cas(k string, exp int, cas uint64, v interface{}, ...) (uint64, error) + func (b *Bucket) CasRaw(k string, exp int, cas uint64, v interface{}, ...) (uint64, error) + func (b *Bucket) CasWithMeta(k string, flags int, exp int, cas uint64, v interface{}, ...) (uint64, *MutationToken, error) + func (b *Bucket) CasWithMetaRaw(k string, flags int, exp int, cas uint64, v interface{}, ...) (uint64, *MutationToken, error) + func (b *Bucket) Close() + func (b *Bucket) CommonAddressSuffix() string + func (b *Bucket) CreateCollection(scope string, collection string) error + func (b *Bucket) CreateScope(scope string) error + func (b *Bucket) Decr(k string, amt, def uint64, exp int, context ...*memcached.ClientContext) (val uint64, err error) + func (b *Bucket) Delete(k string, context ...*memcached.ClientContext) error + func (b *Bucket) DeleteDDoc(docname string) error + func (b *Bucket) Do(k string, f func(mc *memcached.Client, vb uint16) error) (err error) + func (b *Bucket) Do2(k string, f func(mc *memcached.Client, vb uint16) error, deadline bool) (err error) + func (b *Bucket) DropCollection(scope string, collection string) error + func (b *Bucket) DropScope(scope string) error + func (b *Bucket) FlushCollection(scope string, collection string) error + func (b *Bucket) GatherStats(which string) map[string]GatheredStats + func (b *Bucket) GatherStatsFunc(which string, fn func(key, val []byte)) map[string]error + func (b *Bucket) Get(k string, rv interface{}, context ...*memcached.ClientContext) error + func (b *Bucket) GetAndTouchRaw(k string, exp int, context ...*memcached.ClientContext) (data []byte, cas uint64, err error) + func (b *Bucket) GetBulk(keys []string, reqDeadline time.Time, subPaths []string, ...) (map[string]*gomemcached.MCResponse, error) + func (b *Bucket) GetBulkRaw(keys []string, context ...*memcached.ClientContext) (map[string][]byte, error) + func (b *Bucket) GetCollectionCID(scope string, collection string, reqDeadline time.Time) (uint32, uint32, error) + func (b *Bucket) GetCollectionsManifest() (*Manifest, error) + func (b *Bucket) GetCount(refresh bool, context ...*memcached.ClientContext) (count int64, err error) + func (b *Bucket) GetDDoc(docname string, into interface{}) error + func (b *Bucket) GetDDocWithRetry(docname string, into interface{}) error + func (b *Bucket) GetDDocs() (DDocsResult, error) + func (b *Bucket) GetDDocsWithRetry() (DDocsResult, error) + func (b *Bucket) GetFailoverLogs(vBuckets []uint16) (FailoverLog, error) + func (b *Bucket) GetIntStats(refresh bool, which []BucketStats, context ...*memcached.ClientContext) ([]int64, error) + func (b *Bucket) GetMeta(k string, flags *int, expiry *int, cas *uint64, seqNo *uint64, ...) (err error) + func (b *Bucket) GetName() string + func (b *Bucket) GetNodeList(vb uint16) []string + func (b *Bucket) GetPool() *Pool + func (b *Bucket) GetPoolServices(name string) (*PoolServices, error) + func (b *Bucket) GetRandomDoc(context ...*memcached.ClientContext) (*gomemcached.MCResponse, error) + func (b *Bucket) GetRaw(k string, context ...*memcached.ClientContext) ([]byte, error) + func (b *Bucket) GetSize(refresh bool, context ...*memcached.ClientContext) (size int64, err error) + func (b *Bucket) GetStats(which string) map[string]map[string]string + func (b *Bucket) GetUUID() string + func (b *Bucket) GetVBmap(addrs []string) (map[string][]uint16, error) + func (b *Bucket) Gets(k string, rv interface{}, caso *uint64, context ...*memcached.ClientContext) error + func (b *Bucket) GetsMC(key string, reqDeadline time.Time, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error) + func (b *Bucket) GetsRaw(k string, context ...*memcached.ClientContext) (data []byte, flags int, cas uint64, err error) + func (b *Bucket) GetsSubDoc(key string, reqDeadline time.Time, subPaths []string, ...) (*gomemcached.MCResponse, error) + func (b *Bucket) HealthyNodes() []Node + func (b *Bucket) Incr(k string, amt, def uint64, exp int, context ...*memcached.ClientContext) (val uint64, err error) + func (b *Bucket) NodeAddresses() []string + func (b *Bucket) NodeListChanged() bool + func (b *Bucket) Nodes() []Node + func (b *Bucket) OPJobPoll() + func (b *Bucket) Observe(k string) (result memcached.ObserveResult, err error) + func (b *Bucket) ObserveAndPersistPoll(vb uint16, vbuuid uint64, seqNo uint64) (err error, failover bool) + func (b *Bucket) PutDDoc(docname string, value interface{}) error + func (b *Bucket) Refresh() error + func (b *Bucket) RefreshFully() error + func (b *Bucket) ReleaseGetBulkPools(rv map[string]*gomemcached.MCResponse) + func (b *Bucket) RunBucketUpdater(notify NotifyFn) + func (b *Bucket) RunBucketUpdater2(streamingFn StreamingFn, notify NotifyFn) + func (b *Bucket) Set(k string, exp int, v interface{}, context ...*memcached.ClientContext) error + func (b *Bucket) SetObserveAndPersist(nPersist PersistTo, nObserve ObserveTo) (err error) + func (b *Bucket) SetRaw(k string, exp int, v []byte, context ...*memcached.ClientContext) error + func (b *Bucket) SetWithCAS(k string, exp int, v interface{}, context ...*memcached.ClientContext) (uint64, error) + func (b *Bucket) SetWithMeta(k string, flags int, exp int, v interface{}, ...) (*MutationToken, error) + func (b *Bucket) StartOPPollers(maxWorkers int) + func (b *Bucket) StartTapFeed(args *memcached.TapArguments) (*TapFeed, error) + func (b *Bucket) StartUprFeed(name string, sequence uint32) (*UprFeed, error) + func (b *Bucket) StartUprFeedWithConfig(name string, sequence uint32, data_chan_size int, dcp_buffer_size uint32) (*UprFeed, error) + func (b *Bucket) Update(k string, exp int, callback UpdateFunc) error + func (b *Bucket) UpdateBucket() error + func (b *Bucket) UpdateBucket2(streamingFn StreamingFn) error + func (b *Bucket) VBHash(key string) uint32 + func (b *Bucket) VBServerMap() *VBucketServerMap + func (b *Bucket) View(ddoc, name string, params map[string]interface{}) (ViewResult, error) + func (b *Bucket) ViewCustom(ddoc, name string, params map[string]interface{}, vres interface{}) (err error) + func (b *Bucket) ViewURL(ddoc, name string, params map[string]interface{}) (string, error) + func (b *Bucket) WaitForPersistence(k string, cas uint64, deletion bool) error + func (b *Bucket) Write(k string, flags, exp int, v interface{}, opt WriteOptions, ...) (err error) + func (b *Bucket) WriteCas(k string, flags, exp int, cas uint64, v interface{}, opt WriteOptions, ...) (newCas uint64, err error) + func (b *Bucket) WriteCasWithMT(k string, flags, exp int, cas uint64, v interface{}, opt WriteOptions, ...) (newCas uint64, mt *MutationToken, err error) + func (b *Bucket) WriteUpdate(k string, exp int, callback WriteUpdateFunc) error + func (b *Bucket) WriteWithCAS(k string, flags, exp int, v interface{}, opt WriteOptions, ...) (cas uint64, err error) + func (b *Bucket) WriteWithMT(k string, flags, exp int, v interface{}, opt WriteOptions, ...) (mt *MutationToken, err error) + type BucketAuth struct + func (ba *BucketAuth) GetCredentials() (string, string, string) + type BucketInfo struct + Name string + Password string + User string + func GetBucketList(baseU string) (bInfo []BucketInfo, err error) + type BucketNotFoundError struct + func (e *BucketNotFoundError) Error() string + type BucketStats int + type Client struct + BaseURL *url.URL + Info Pools + func Connect(baseU string) (Client, error) + func ConnectWithAuth(baseU string, ah AuthHandler) (c Client, err error) + func ConnectWithAuthCreds(baseU, username, password string) (c Client, err error) + func (c *Client) ClearTLS() + func (c *Client) GetAuditSpec() (*AuditSpec, error) + func (c *Client) GetPool(name string) (p Pool, err error) + func (c *Client) GetPoolServices(name string) (ps PoolServices, err error) + func (c *Client) GetRolesAll() ([]RoleDescription, error) + func (c *Client) GetUserInfoAll() ([]User, error) + func (c *Client) GetUserRoles() ([]interface{}, error) + func (c *Client) InitTLS(certFile string) error + func (c *Client) ProcessStream(path string, callb func(interface{}) error, data interface{}) error + func (c *Client) PutUserInfo(u *User) error + type Collection struct + Name string + Uid uint64 + type DDoc struct + Language string + Views map[string]ViewDefinition + type DDocsResult struct + Rows []struct{ ... } + type DocID string + type DurablitySettings struct + Observe ObserveTo + Persist PersistTo + type FailoverLog map[uint16]memcached.FailoverLog + type FeedInfo struct + type GatheredStats struct + Err error + Server string + Stats map[string]string + type GenericMcdAuthHandler interface + AuthenticateMemcachedConn func(host string, conn *memcached.Client) error + type HTTPAuthHandler interface + SetCredsForRequest func(req *http.Request) error + type InputCollection struct + Name string + Uid string + type InputManifest struct + Scopes []InputScope + Uid string + type InputScope struct + Collections []InputCollection + Name string + Uid string + type JobType uint8 + type Manifest struct + Scopes map[string]*Scope + Uid uint64 + type MultiBucketAuthHandler interface + ForBucket func(bucket string) AuthHandler + type MutationToken struct + Guard uint64 + VBid uint16 + Value uint64 + type Node struct + AlternateNames map[string]NodeAlternateNames + ClusterCompatibility int + ClusterMembership string + CouchAPIBase string + Hostname string + InterestingStats map[string]float64 + MCDMemoryAllocated float64 + MCDMemoryReserved float64 + MemoryFree float64 + MemoryTotal float64 + OS string + Ports map[string]int + Services []string + Status string + ThisNode bool + Uptime int + Version string + type NodeAlternateNames struct + Hostname string + Ports map[string]int + type NodeServices struct + AlternateNames map[string]NodeAlternateNames + Hostname string + Services map[string]int + ThisNode bool + type NotifyFn func(bucket string, err error) + type OPErrResponse struct + type OPpool struct + func NewPool(max int) *OPpool + func (p *OPpool) Get() *ObservePersistJob + func (p *OPpool) Put(o *ObservePersistJob) + type ObservePersistJob struct + type ObserveTo uint8 + type PersistTo uint8 + type Pool struct + BucketMap map[string]*Bucket + BucketURL map[string]string + CbasMemoryQuota float64 + EventingMemoryQuota float64 + FtsMemoryQuota float64 + IndexMemoryQuota float64 + MemoryQuota float64 + Nodes []Node + func (p *Pool) Close() + func (p *Pool) GetBucket(name string) (*Bucket, error) + func (p *Pool) GetBucketWithAuth(bucket, username, password string) (*Bucket, error) + func (p *Pool) GetClient() *Client + type PoolServices struct + Capabilities json.RawMessage + NodesExt []NodeServices + Rev int + func ParsePoolServices(jsonInput string) (*PoolServices, error) + type Pools struct + ComponentsVersion map[string]string + ImplementationVersion string + IsAdmin bool + Pools []RestPool + UUID string + type RestPool struct + Name string + StreamingURI string + URI string + type Role struct + BucketName string + CollectionName string + Role string + ScopeName string + type RoleDescription struct + BucketName string + Ce bool + Desc string + Name string + Role string + type Scope struct + Collections map[string]*Collection + Name string + Uid uint64 + type StreamingFn func(bucket *Bucket) + type TapFeed struct + C <-chan memcached.TapEvent + func (feed *TapFeed) Close() error + type UpdateFunc func(current []byte) (updated []byte, err error) + type UprFeed struct + C <-chan *memcached.UprEvent + func (feed *UprFeed) Close() error + func (feed *UprFeed) UprCloseStream(vb, opaqueMSB uint16) error + func (feed *UprFeed) UprRequestStream(vb uint16, opaque uint16, flags uint32, ...) error + type User struct + Domain string + Id string + Name string + Roles []Role + type VBucketServerMap struct + HashAlgorithm string + NumReplicas int + ServerList []string + VBucketMap [][]int + type ViewDefinition struct + Map string + Reduce string + type ViewError struct + From string + Reason string + func (ve ViewError) Error() string + type ViewResult struct + Errors []ViewError + Rows []ViewRow + TotalRows int + type ViewRow struct + Doc *interface{} + ID string + Key interface{} + Value interface{} + type WriteOptions int + func (w WriteOptions) String() string + type WriteUpdateFunc func(current []byte) (updated []byte, opt WriteOptions, err error)