riak

package module

Go to main page

Versions in this module

v1

v1.3.0

Sep 22, 2015

Changes in this version

+ var ErrConnectionManagerMaxMustBeGreaterThanMin = newClientError(...)

type Client

+ func (c *Client) Ping() (bool, error)

type ClusterOptions

+ NoDefaultNode bool

v1.2.0

Sep 9, 2015

Changes in this version

type DeleteIndexCommand

+ func (cmd *DeleteIndexCommand) Error() error

+ func (cmd *DeleteIndexCommand) Success() bool

type DeleteValueCommand

+ func (cmd *DeleteValueCommand) Error() error

+ func (cmd *DeleteValueCommand) Success() bool

type FetchBucketPropsCommand

+ func (cmd *FetchBucketPropsCommand) Error() error

+ func (cmd *FetchBucketPropsCommand) Success() bool

type FetchCounterCommand

+ func (cmd *FetchCounterCommand) Error() error

+ func (cmd *FetchCounterCommand) Success() bool

type FetchIndexCommand

+ func (cmd *FetchIndexCommand) Error() error

+ func (cmd *FetchIndexCommand) Success() bool

type FetchMapCommand

+ func (cmd *FetchMapCommand) Error() error

+ func (cmd *FetchMapCommand) Success() bool

type FetchPreflistCommand

+ func (cmd *FetchPreflistCommand) Error() error

+ func (cmd *FetchPreflistCommand) Success() bool

type FetchSchemaCommand

+ func (cmd *FetchSchemaCommand) Error() error

+ func (cmd *FetchSchemaCommand) Success() bool

type FetchSetCommand

+ func (cmd *FetchSetCommand) Error() error

+ func (cmd *FetchSetCommand) Success() bool

type FetchValueCommand

+ func (cmd *FetchValueCommand) Error() error

+ func (cmd *FetchValueCommand) Success() bool

type ListBucketsCommand

+ func (cmd *ListBucketsCommand) Error() error

+ func (cmd *ListBucketsCommand) Success() bool

type ListKeysCommand

+ func (cmd *ListKeysCommand) Error() error

+ func (cmd *ListKeysCommand) Success() bool

type MapReduceCommand

+ func (cmd *MapReduceCommand) Error() error

+ func (cmd *MapReduceCommand) Success() bool

type PingCommand

+ func (cmd *PingCommand) Error() error

+ func (cmd *PingCommand) Success() bool

type SearchCommand

+ func (cmd *SearchCommand) Error() error

+ func (cmd *SearchCommand) Success() bool

type SecondaryIndexQueryCommand

+ func (cmd *SecondaryIndexQueryCommand) Error() error

+ func (cmd *SecondaryIndexQueryCommand) Success() bool

type StoreBucketPropsCommand

+ func (cmd *StoreBucketPropsCommand) Error() error

+ func (cmd *StoreBucketPropsCommand) Success() bool

type StoreIndexCommand

+ func (cmd *StoreIndexCommand) Error() error

+ func (cmd *StoreIndexCommand) Success() bool

type StoreSchemaCommand

+ func (cmd *StoreSchemaCommand) Error() error

+ func (cmd *StoreSchemaCommand) Success() bool

type StoreValueCommand

+ func (cmd *StoreValueCommand) Error() error

+ func (cmd *StoreValueCommand) Success() bool

type UpdateCounterCommand

+ func (cmd *UpdateCounterCommand) Error() error

+ func (cmd *UpdateCounterCommand) Success() bool

type UpdateMapCommand

+ func (cmd *UpdateMapCommand) Error() error

+ func (cmd *UpdateMapCommand) Success() bool

type UpdateSetCommand

+ func (cmd *UpdateSetCommand) Error() error

+ func (cmd *UpdateSetCommand) Success() bool

v1.1.0

Aug 28, 2015

Changes in this version

+ const ErrClientInvalidRemoteAddress

type ClientError

+ InnerError error

type Command

+ Error func() error

v1.0.0

Aug 26, 2015

Changes in this version

+ var EnableDebugLogging = false

+ var ErrAddressRequired = newClientError("RemoteAddress is required in options")

+ var ErrAuthMissingConfig = newClientError("[Connection] authentication is missing TLS config")

+ var ErrAuthTLSUpgradeFailed = newClientError("[Connection] upgrading to TLS connection failed")

+ var ErrBucketRequired = newClientError("Bucket is required")

+ var ErrCannotRead = errors.New("Cannot read from a non-active or closed connection")

+ var ErrCannotWrite = errors.New("Cannot write to a non-active or closed connection")

+ var ErrClientMissingRequiredData = newClientError("[Client] options must specify either a Cluster or a set of RemoteAddresses")

+ var ErrClientOptionsRequired = newClientError("[Client] options are required")

+ var ErrClusterAsyncRequiresChannelOrWaitGroup = newClientError(...)

+ var ErrClusterCommandRequired = newClientError("[Cluster] Command must be non-nil")

+ var ErrClusterEnqueueWhileShuttingDown = newClientError("[Cluster] will not enqueue command, shutting down")

+ var ErrClusterNoNodesAvailable = newClientError("[Cluster] all retries exhausted and/or no nodes available to execute command")

+ var ErrClusterNodeMustBeNonNil = newClientError("[Cluster] node argument must be non-nil")

+ var ErrClusterShuttingDown = newClientError("[Cluster] will not execute command, shutting down")

+ var ErrConnMgrAllConnectionsInUse = newClientError("[connectionManager] all connections in use at max connections reached")

+ var ErrConnectionManagerRequiresAddress = newClientError("[connectionManager] new manager requires non-nil address")

+ var ErrConnectionManagerRequiresOptions = newClientError("[connectionManager] new manager requires options")

+ var ErrConnectionManagerRequiresStopChannel = newClientError("[connectionManager] new manager requires non-nil stop channel")

+ var ErrDefaultNodeManagerRequiresNode = newClientError("Must pass at least one node to default node manager")

+ var ErrKeyRequired = newClientError("Key is required")

+ var ErrNilOptions = newClientError("[Command] options must be non-nil")

+ var ErrNoNodesAvailable = newClientError("No nodes available to execute command, or exhausted all tries")

+ var ErrOptionsRequired = newClientError("Options are required")

+ var ErrZeroLength = newClientError("[Command] 0 byte data response")

+ type Async struct

+ Command Command

+ Done chan Command

+ Error error

+ Wait *sync.WaitGroup

+ type AuthCommand struct

+ Password string

+ User string

+ func (cmd *AuthCommand) Name() string

+ type AuthOptions struct

+ Password string

+ TlsConfig *tls.Config

+ User string

+ type Client struct

+ func NewClient(opts *NewClientOptions) (*Client, error)

+ func (c *Client) Cluster() *Cluster

+ func (c *Client) Execute(cmd Command) error

+ func (c *Client) ExecuteAsync(a *Async) error

+ func (c *Client) Stop() error

+ type ClientError struct

+ Errmsg string

+ func (e ClientError) Error() (s string)

+ type Cluster struct

+ func NewCluster(options *ClusterOptions) (c *Cluster, err error)

+ func (c *Cluster) AddNode(n *Node) error

+ func (c *Cluster) Execute(command Command) (err error)

+ func (c *Cluster) ExecuteAsync(async *Async) (err error)

+ func (c *Cluster) RemoveNode(n *Node) error

+ func (c *Cluster) Start() error

+ func (c *Cluster) Stop() (err error)

+ func (c *Cluster) String() string

+ type ClusterOptions struct

+ ExecutionAttempts byte

+ NodeManager NodeManager

+ Nodes []*Node

+ QueueExecutionInterval time.Duration

+ QueueMaxDepth uint16

+ type Command interface

+ Name func() string

+ Success func() bool

+ type CommandBuilder interface

+ Build func() (Command, error)

+ type CommandImpl struct

+ Error error

+ func (cmd *CommandImpl) Success() bool

+ type CommitHook struct

+ ModFun *ModFun

+ Name string

+ type ConflictResolver interface

+ Resolve func([]*Object) []*Object

+ type DeleteIndexCommand struct

+ Response bool

+ func (cmd *DeleteIndexCommand) Name() string

+ type DeleteIndexCommandBuilder struct

+ func NewDeleteIndexCommandBuilder() *DeleteIndexCommandBuilder

+ func (builder *DeleteIndexCommandBuilder) Build() (Command, error)

+ func (builder *DeleteIndexCommandBuilder) WithIndexName(indexName string) *DeleteIndexCommandBuilder

+ type DeleteValueCommand struct

+ Response bool

+ func (cmd *DeleteValueCommand) Name() string

+ type DeleteValueCommandBuilder struct

+ func NewDeleteValueCommandBuilder() *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) Build() (Command, error)

+ func (builder *DeleteValueCommandBuilder) WithBucket(bucket string) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithBucketType(bucketType string) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithDw(dw uint32) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithKey(key string) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithPr(pr uint32) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithPw(pw uint32) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithR(r uint32) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithRw(rw uint32) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithTimeout(timeout time.Duration) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithVClock(vclock []byte) *DeleteValueCommandBuilder

+ func (builder *DeleteValueCommandBuilder) WithW(w uint32) *DeleteValueCommandBuilder

+ type FetchBucketPropsCommand struct

+ Response *FetchBucketPropsResponse

+ func (cmd *FetchBucketPropsCommand) Name() string

+ type FetchBucketPropsCommandBuilder struct

+ func NewFetchBucketPropsCommandBuilder() *FetchBucketPropsCommandBuilder

+ func (builder *FetchBucketPropsCommandBuilder) Build() (Command, error)

+ func (builder *FetchBucketPropsCommandBuilder) WithBucket(bucket string) *FetchBucketPropsCommandBuilder

+ func (builder *FetchBucketPropsCommandBuilder) WithBucketType(bucketType string) *FetchBucketPropsCommandBuilder

+ type FetchBucketPropsResponse struct

+ AllowMult bool

+ Backend string

+ BasicQuorum bool

+ BigVClock uint32

+ ChashKeyFun *ModFun

+ Consistent bool

+ DataType string

+ Dw uint32

+ HasPostcommit bool

+ HasPrecommit bool

+ LastWriteWins bool

+ LinkFun *ModFun

+ NVal uint32

+ NotFoundOk bool

+ OldVClock uint32

+ PostCommit []*CommitHook

+ Pr uint32

+ PreCommit []*CommitHook

+ Pw uint32

+ R uint32

+ Repl ReplMode

+ Rw uint32

+ Search bool

+ SearchIndex string

+ SmallVClock uint32

+ W uint32

+ YoungVClock uint32

+ type FetchCounterCommand struct

+ Response *FetchCounterResponse

+ func (cmd *FetchCounterCommand) Name() string

+ type FetchCounterCommandBuilder struct

+ func NewFetchCounterCommandBuilder() *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) Build() (Command, error)

+ func (builder *FetchCounterCommandBuilder) WithBasicQuorum(basicQuorum bool) *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) WithBucket(bucket string) *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) WithBucketType(bucketType string) *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) WithKey(key string) *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) WithNotFoundOk(notFoundOk bool) *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) WithPr(pr uint32) *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) WithR(r uint32) *FetchCounterCommandBuilder

+ func (builder *FetchCounterCommandBuilder) WithTimeout(timeout time.Duration) *FetchCounterCommandBuilder

+ type FetchCounterResponse struct

+ CounterValue int64

+ IsNotFound bool

+ type FetchIndexCommand struct

+ Response []*SearchIndex

+ func (cmd *FetchIndexCommand) Name() string

+ type FetchIndexCommandBuilder struct

+ func NewFetchIndexCommandBuilder() *FetchIndexCommandBuilder

+ func (builder *FetchIndexCommandBuilder) Build() (Command, error)

+ func (builder *FetchIndexCommandBuilder) WithIndexName(indexName string) *FetchIndexCommandBuilder

+ type FetchMapCommand struct

+ Response *FetchMapResponse

+ func (cmd *FetchMapCommand) Name() string

+ type FetchMapCommandBuilder struct

+ func NewFetchMapCommandBuilder() *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) Build() (Command, error)

+ func (builder *FetchMapCommandBuilder) WithBasicQuorum(basicQuorum bool) *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) WithBucket(bucket string) *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) WithBucketType(bucketType string) *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) WithKey(key string) *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) WithNotFoundOk(notFoundOk bool) *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) WithPr(pr uint32) *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) WithR(r uint32) *FetchMapCommandBuilder

+ func (builder *FetchMapCommandBuilder) WithTimeout(timeout time.Duration) *FetchMapCommandBuilder

+ type FetchMapResponse struct

+ Context []byte

+ IsNotFound bool

+ Map *Map

+ type FetchPreflistCommand struct

+ Response *FetchPreflistResponse

+ func (cmd *FetchPreflistCommand) Name() string

+ type FetchPreflistCommandBuilder struct

+ func NewFetchPreflistCommandBuilder() *FetchPreflistCommandBuilder

+ func (builder *FetchPreflistCommandBuilder) Build() (Command, error)

+ func (builder *FetchPreflistCommandBuilder) WithBucket(bucket string) *FetchPreflistCommandBuilder

+ func (builder *FetchPreflistCommandBuilder) WithBucketType(bucketType string) *FetchPreflistCommandBuilder

+ func (builder *FetchPreflistCommandBuilder) WithKey(key string) *FetchPreflistCommandBuilder

+ type FetchPreflistResponse struct

+ Preflist []*PreflistItem

+ type FetchSchemaCommand struct

+ Response *Schema

+ func (cmd *FetchSchemaCommand) Name() string

+ type FetchSchemaCommandBuilder struct

+ func NewFetchSchemaCommandBuilder() *FetchSchemaCommandBuilder

+ func (builder *FetchSchemaCommandBuilder) Build() (Command, error)

+ func (builder *FetchSchemaCommandBuilder) WithSchemaName(schemaName string) *FetchSchemaCommandBuilder

+ type FetchSetCommand struct

+ Response *FetchSetResponse

+ func (cmd *FetchSetCommand) Name() string

+ type FetchSetCommandBuilder struct

+ func NewFetchSetCommandBuilder() *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) Build() (Command, error)

+ func (builder *FetchSetCommandBuilder) WithBasicQuorum(basicQuorum bool) *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) WithBucket(bucket string) *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) WithBucketType(bucketType string) *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) WithKey(key string) *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) WithNotFoundOk(notFoundOk bool) *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) WithPr(pr uint32) *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) WithR(r uint32) *FetchSetCommandBuilder

+ func (builder *FetchSetCommandBuilder) WithTimeout(timeout time.Duration) *FetchSetCommandBuilder

+ type FetchSetResponse struct

+ Context []byte

+ IsNotFound bool

+ SetValue [][]byte

+ type FetchValueCommand struct

+ Response *FetchValueResponse

+ func (cmd *FetchValueCommand) Name() string

+ type FetchValueCommandBuilder struct

+ func NewFetchValueCommandBuilder() *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) Build() (Command, error)

+ func (builder *FetchValueCommandBuilder) WithBasicQuorum(basicQuorum bool) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithBucket(bucket string) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithBucketType(bucketType string) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithConflictResolver(resolver ConflictResolver) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithHeadOnly(headOnly bool) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithIfModified(ifModified []byte) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithKey(key string) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithNVal(nval uint32) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithNotFoundOk(notFoundOk bool) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithPr(pr uint32) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithR(r uint32) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithReturnDeletedVClock(returnDeletedVClock bool) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithSloppyQuorum(sloppyQuorum bool) *FetchValueCommandBuilder

+ func (builder *FetchValueCommandBuilder) WithTimeout(timeout time.Duration) *FetchValueCommandBuilder

+ type FetchValueResponse struct

+ IsNotFound bool

+ IsUnchanged bool

+ VClock []byte

+ Values []*Object

+ type Link struct

+ Bucket string

+ Key string

+ Tag string

+ type ListBucketsCommand struct

+ Response *ListBucketsResponse

+ func (cmd *ListBucketsCommand) Done() bool

+ func (cmd *ListBucketsCommand) Name() string

+ type ListBucketsCommandBuilder struct

+ func NewListBucketsCommandBuilder() *ListBucketsCommandBuilder

+ func (builder *ListBucketsCommandBuilder) Build() (Command, error)

+ func (builder *ListBucketsCommandBuilder) WithBucketType(bucketType string) *ListBucketsCommandBuilder

+ func (builder *ListBucketsCommandBuilder) WithCallback(callback func([]string) error) *ListBucketsCommandBuilder

+ func (builder *ListBucketsCommandBuilder) WithStreaming(streaming bool) *ListBucketsCommandBuilder

+ func (builder *ListBucketsCommandBuilder) WithTimeout(timeout time.Duration) *ListBucketsCommandBuilder

+ type ListBucketsResponse struct

+ Buckets []string

+ type ListKeysCommand struct

+ Response *ListKeysResponse

+ func (cmd *ListKeysCommand) Done() bool

+ func (cmd *ListKeysCommand) Name() string

+ type ListKeysCommandBuilder struct

+ func NewListKeysCommandBuilder() *ListKeysCommandBuilder

+ func (builder *ListKeysCommandBuilder) Build() (Command, error)

+ func (builder *ListKeysCommandBuilder) WithBucket(bucket string) *ListKeysCommandBuilder

+ func (builder *ListKeysCommandBuilder) WithBucketType(bucketType string) *ListKeysCommandBuilder

+ func (builder *ListKeysCommandBuilder) WithCallback(callback func([]string) error) *ListKeysCommandBuilder

+ func (builder *ListKeysCommandBuilder) WithStreaming(streaming bool) *ListKeysCommandBuilder

+ func (builder *ListKeysCommandBuilder) WithTimeout(timeout time.Duration) *ListKeysCommandBuilder

+ type ListKeysResponse struct

+ Keys []string

+ type Map struct

+ Counters map[string]int64

+ Flags map[string]bool

+ Maps map[string]*Map

+ Registers map[string][]byte

+ Sets map[string][][]byte

+ type MapOperation struct

+ func (mapOp *MapOperation) AddToSet(key string, value []byte) *MapOperation

+ func (mapOp *MapOperation) IncrementCounter(key string, increment int64) *MapOperation

+ func (mapOp *MapOperation) Map(key string) *MapOperation

+ func (mapOp *MapOperation) RemoveCounter(key string) *MapOperation

+ func (mapOp *MapOperation) RemoveFlag(key string) *MapOperation

+ func (mapOp *MapOperation) RemoveFromSet(key string, value []byte) *MapOperation

+ func (mapOp *MapOperation) RemoveMap(key string) *MapOperation

+ func (mapOp *MapOperation) RemoveRegister(key string) *MapOperation

+ func (mapOp *MapOperation) RemoveSet(key string) *MapOperation

+ func (mapOp *MapOperation) SetFlag(key string, value bool) *MapOperation

+ func (mapOp *MapOperation) SetRegister(key string, value []byte) *MapOperation

+ type MapReduceCommand struct

+ Response [][]byte

+ func (cmd *MapReduceCommand) Done() bool

+ func (cmd *MapReduceCommand) Name() string

+ type MapReduceCommandBuilder struct

+ func NewMapReduceCommandBuilder() *MapReduceCommandBuilder

+ func (builder *MapReduceCommandBuilder) Build() (Command, error)

+ func (builder *MapReduceCommandBuilder) WithCallback(callback func([]byte) error) *MapReduceCommandBuilder

+ func (builder *MapReduceCommandBuilder) WithQuery(query string) *MapReduceCommandBuilder

+ func (builder *MapReduceCommandBuilder) WithStreaming(streaming bool) *MapReduceCommandBuilder

+ type ModFun struct

+ Function string

+ Module string

+ type NewClientOptions struct

+ Cluster *Cluster

+ Port uint16

+ RemoteAddresses []string

+ type Node struct

+ func NewNode(options *NodeOptions) (*Node, error)

+ func (n *Node) String() string

+ type NodeManager interface

+ ExecuteOnNode func(command Command, previousNode *Node) (bool, error)

+ Init func(nodes []*Node) error

+ Stop func()

+ type NodeOptions struct

+ AuthOptions *AuthOptions

+ ConnectTimeout time.Duration

+ HealthCheckBuilder CommandBuilder

+ HealthCheckInterval time.Duration

+ IdleTimeout time.Duration

+ MaxConnections uint16

+ MinConnections uint16

+ RemoteAddress string

+ RequestTimeout time.Duration

+ type Object struct

+ Bucket string

+ BucketType string

+ Charset string

+ ContentEncoding string

+ ContentType string

+ Indexes map[string][]string

+ IsTombstone bool

+ Key string

+ LastModified time.Time

+ Links []*Link

+ UserMeta []*Pair

+ VClock []byte

+ VTag string

+ Value []byte

+ func (o *Object) AddToIndex(indexName string, indexValue string)

+ func (o *Object) AddToIntIndex(indexName string, indexValue int)

+ func (o *Object) HasIndexes() bool

+ func (o *Object) HasLinks() bool

+ func (o *Object) HasUserMeta() bool

+ type Pair struct

+ Key string

+ Value string

+ type PingCommand struct

+ func (cmd *PingCommand) Name() string

+ type PingCommandBuilder struct

+ func (builder *PingCommandBuilder) Build() (Command, error)

+ type PreflistItem struct

+ Node string

+ Partition int64

+ Primary bool

+ type ReplMode int32

+ const FALSE

+ const FULLSYNC

+ const REALTIME

+ const TRUE

+ type RiakError struct

+ Errcode uint32

+ Errmsg string

+ func (e RiakError) Error() (s string)

+ type Schema struct

+ Content string

+ Name string

+ type SearchCommand struct

+ Response *SearchResponse

+ func (cmd *SearchCommand) Name() string

+ type SearchCommandBuilder struct

+ func NewSearchCommandBuilder() *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) Build() (Command, error)

+ func (builder *SearchCommandBuilder) WithDefaultField(defaultField string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithDefaultOperation(op string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithFilterQuery(filterQuery string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithIndexName(index string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithNumRows(numRows uint32) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithPresort(presort string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithQuery(query string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithReturnFields(fields ...string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithSortField(sortField string) *SearchCommandBuilder

+ func (builder *SearchCommandBuilder) WithStart(start uint32) *SearchCommandBuilder

+ type SearchDoc struct

+ Bucket string

+ BucketType string

+ Fields map[string][]string

+ Id string

+ Key string

+ Score string

+ type SearchIndex struct

+ NVal uint32

+ Name string

+ Schema string

+ type SearchResponse struct

+ Docs []*SearchDoc

+ MaxScore float32

+ NumFound uint32

+ type SecondaryIndexQueryCommand struct

+ Response *SecondaryIndexQueryResponse

+ func (cmd *SecondaryIndexQueryCommand) Done() bool

+ func (cmd *SecondaryIndexQueryCommand) Name() string

+ type SecondaryIndexQueryCommandBuilder struct

+ func NewSecondaryIndexQueryCommandBuilder() *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) Build() (Command, error)

+ func (builder *SecondaryIndexQueryCommandBuilder) WithBucket(bucket string) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithBucketType(bucketType string) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithCallback(callback func([]*SecondaryIndexQueryResult) error) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithContinuation(cont []byte) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithIndexKey(key string) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithIndexName(indexName string) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithIntRange(min int64, max int64) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithMaxResults(maxResults uint32) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithPaginationSort(paginationSort bool) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithRange(min string, max string) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithReturnKeyAndIndex(val bool) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithStreaming(streaming bool) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithTermRegex(regex string) *SecondaryIndexQueryCommandBuilder

+ func (builder *SecondaryIndexQueryCommandBuilder) WithTimeout(timeout time.Duration) *SecondaryIndexQueryCommandBuilder

+ type SecondaryIndexQueryResponse struct

+ Continuation []byte

+ Results []*SecondaryIndexQueryResult

+ type SecondaryIndexQueryResult struct

+ IndexKey []byte

+ ObjectKey []byte

+ type StartTlsCommand struct

+ func (cmd *StartTlsCommand) Name() string

+ type StoreBucketPropsCommand struct

+ func (cmd *StoreBucketPropsCommand) Name() string

+ type StoreBucketPropsCommandBuilder struct

+ func NewStoreBucketPropsCommandBuilder() *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) AddPostCommit(commitHook *CommitHook) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) AddPreCommit(commitHook *CommitHook) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) Build() (Command, error)

+ func (builder *StoreBucketPropsCommandBuilder) WithAllowMult(allowMult bool) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithBackend(backend string) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithBasicQuorum(basicQuorum bool) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithBigVClock(bigVClock uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithBucket(bucket string) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithBucketType(bucketType string) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithChashKeyFun(val *ModFun) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithDw(dw uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithLastWriteWins(lww bool) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithNVal(nval uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithNotFoundOk(notFoundOk bool) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithOldVClock(oldVClock uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithPr(pr uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithPw(pw uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithR(r uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithRw(rw uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithSearch(search bool) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithSearchIndex(searchIndex string) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithSmallVClock(smallVClock uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithW(w uint32) *StoreBucketPropsCommandBuilder

+ func (builder *StoreBucketPropsCommandBuilder) WithYoungVClock(youngVClock uint32) *StoreBucketPropsCommandBuilder

+ type StoreIndexCommand struct

+ Response bool

+ func (cmd *StoreIndexCommand) Name() string

+ type StoreIndexCommandBuilder struct

+ func NewStoreIndexCommandBuilder() *StoreIndexCommandBuilder

+ func (builder *StoreIndexCommandBuilder) Build() (Command, error)

+ func (builder *StoreIndexCommandBuilder) WithIndexName(indexName string) *StoreIndexCommandBuilder

+ func (builder *StoreIndexCommandBuilder) WithNVal(nval uint32) *StoreIndexCommandBuilder

+ func (builder *StoreIndexCommandBuilder) WithSchemaName(schemaName string) *StoreIndexCommandBuilder

+ func (builder *StoreIndexCommandBuilder) WithTimeout(timeout time.Duration) *StoreIndexCommandBuilder

+ type StoreSchemaCommand struct

+ Response bool

+ func (cmd *StoreSchemaCommand) Name() string

+ type StoreSchemaCommandBuilder struct

+ func NewStoreSchemaCommandBuilder() *StoreSchemaCommandBuilder

+ func (builder *StoreSchemaCommandBuilder) Build() (Command, error)

+ func (builder *StoreSchemaCommandBuilder) WithSchema(schema string) *StoreSchemaCommandBuilder

+ func (builder *StoreSchemaCommandBuilder) WithSchemaName(schemaName string) *StoreSchemaCommandBuilder

+ type StoreValueCommand struct

+ Response *StoreValueResponse

+ func (cmd *StoreValueCommand) Name() string

+ type StoreValueCommandBuilder struct

+ func NewStoreValueCommandBuilder() *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) Build() (Command, error)

+ func (builder *StoreValueCommandBuilder) WithAsis(asis bool) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithBucket(bucket string) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithBucketType(bucketType string) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithConflictResolver(resolver ConflictResolver) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithContent(object *Object) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithDw(dw uint32) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithIfNoneMatch(ifNoneMatch bool) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithIfNotModified(ifNotModified bool) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithKey(key string) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithNVal(nval uint32) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithPw(pw uint32) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithReturnBody(returnBody bool) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithReturnHead(returnHead bool) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithSloppyQuorum(sloppyQuorum bool) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithTimeout(timeout time.Duration) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithVClock(vclock []byte) *StoreValueCommandBuilder

+ func (builder *StoreValueCommandBuilder) WithW(w uint32) *StoreValueCommandBuilder

+ type StoreValueResponse struct

+ GeneratedKey string

+ VClock []byte

+ Values []*Object

+ type StreamingCommand interface

+ Done func() bool

+ type UpdateCounterCommand struct

+ Response *UpdateCounterResponse

+ func (cmd *UpdateCounterCommand) Name() string

+ type UpdateCounterCommandBuilder struct

+ func NewUpdateCounterCommandBuilder() *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) Build() (Command, error)

+ func (builder *UpdateCounterCommandBuilder) WithBucket(bucket string) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithBucketType(bucketType string) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithDw(dw uint32) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithIncrement(increment int64) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithKey(key string) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithPw(pw uint32) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithReturnBody(returnBody bool) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithTimeout(timeout time.Duration) *UpdateCounterCommandBuilder

+ func (builder *UpdateCounterCommandBuilder) WithW(w uint32) *UpdateCounterCommandBuilder

+ type UpdateCounterResponse struct

+ CounterValue int64

+ GeneratedKey string

+ type UpdateMapCommand struct

+ Response *UpdateMapResponse

+ func (cmd *UpdateMapCommand) Name() string

+ type UpdateMapCommandBuilder struct

+ func NewUpdateMapCommandBuilder() *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) Build() (Command, error)

+ func (builder *UpdateMapCommandBuilder) WithBucket(bucket string) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithBucketType(bucketType string) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithContext(context []byte) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithDw(dw uint32) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithKey(key string) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithMapOperation(mapOperation *MapOperation) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithPw(pw uint32) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithReturnBody(returnBody bool) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithTimeout(timeout time.Duration) *UpdateMapCommandBuilder

+ func (builder *UpdateMapCommandBuilder) WithW(w uint32) *UpdateMapCommandBuilder

+ type UpdateMapResponse struct

+ Context []byte

+ GeneratedKey string

+ Map *Map

+ type UpdateSetCommand struct

+ Response *UpdateSetResponse

+ func (cmd *UpdateSetCommand) Name() string

+ type UpdateSetCommandBuilder struct

+ func NewUpdateSetCommandBuilder() *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) Build() (Command, error)

+ func (builder *UpdateSetCommandBuilder) WithAdditions(adds ...[]byte) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithBucket(bucket string) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithBucketType(bucketType string) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithContext(context []byte) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithDw(dw uint32) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithKey(key string) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithPw(pw uint32) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithRemovals(removals ...[]byte) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithReturnBody(returnBody bool) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithTimeout(timeout time.Duration) *UpdateSetCommandBuilder

+ func (builder *UpdateSetCommandBuilder) WithW(w uint32) *UpdateSetCommandBuilder

+ type UpdateSetResponse struct

+ Context []byte

+ GeneratedKey string

+ SetValue [][]byte

v1.0.0-beta1

Aug 7, 2015

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