aerospike

package module

Go to main page

Versions in this module

v1

v1.4.0

Feb 17, 2015

Changes in this version

type Client

+ func (clnt *Client) GetObject(policy *BasePolicy, key *Key, obj interface{}) error

+ func (clnt *Client) PutObject(policy *WritePolicy, key *Key, obj interface{}) (err error)

type Recordset

+ func (rcs *Recordset) Results() <-chan *result

+ type SyncMap struct

v1.3.1

Jan 26, 2015

v1.3.0

Jan 20, 2015

Changes in this version

+ type AdminCommand struct

+ type AdminPolicy struct

+ Timeout time.Duration

+ func NewAdminPolicy() *AdminPolicy

type Client

+ DefaultAdminPolicy *AdminPolicy

+ func (clnt *Client) ChangePassword(policy *AdminPolicy, user string, password string) error

+ func (clnt *Client) CreateUser(policy *AdminPolicy, user string, password string, roles []string) error

+ func (clnt *Client) DropUser(policy *AdminPolicy, user string) error

+ func (clnt *Client) GrantRoles(policy *AdminPolicy, user string, roles []string) error

+ func (clnt *Client) QueryNode(policy *QueryPolicy, node *Node, statement *Statement) (*Recordset, error)

+ func (clnt *Client) QueryUser(policy *AdminPolicy, user string) (*UserRoles, error)

+ func (clnt *Client) QueryUsers(policy *AdminPolicy) ([]*UserRoles, error)

+ func (clnt *Client) ReplaceRoles(policy *AdminPolicy, user string, roles []string) error

+ func (clnt *Client) RevokeRoles(policy *AdminPolicy, user string, roles []string) error

type ClientPolicy

+ Password string

+ TendInterval time.Duration

+ User string

+ func (cp *ClientPolicy) RequiresAuthentication() bool

+ type Role string

+ const Read

+ const ReadWrite

+ const SysAdmin

+ const UserAdmin

+ type UserRoles struct

+ Roles []string

+ User string

v1.2.0

Dec 29, 2014

Changes in this version

+ const CONSISTENCY_ALL

+ const CONSISTENCY_ONE

type BasePolicy

+ ConsistencyLevel ConsistencyLevel

+ type CommitLevel int

+ const COMMIT_ALL

+ const COMMIT_MASTER

+ type ConsistencyLevel int

type Key

+ func NewKeyWithDigest(namespace string, setName string, key interface{}, digest []byte) (newKey *Key, err error)

+ func (ky *Key) SetDigest(digest []byte) error

type LargeList

+ func (ll *LargeList) Range(minValue, maxValue interface{}) ([]interface{}, error)

+ func (ll *LargeList) RangeThenFilter(minValue, maxValue interface{}, filterName string, filterArgs ...interface{}) ([]interface{}, error)

type LargeMap

+ func (lm *LargeMap) Exists(keyValue interface{}) (bool, error)

type WritePolicy

+ CommitLevel CommitLevel

v1.1.2

Dec 19, 2014

v1.1.1

Dec 10, 2014

v1.1.0

Nov 28, 2014

Changes in this version

type Client

+ DefaultPolicy *BasePolicy

+ DefaultQueryPolicy *QueryPolicy

+ DefaultScanPolicy *ScanPolicy

+ DefaultWritePolicy *WritePolicy

v1.0.3

Nov 24, 2014

v1.0.2

Nov 2, 2014

Changes in this version

type LargeList

+ func (ll *LargeList) Update(values ...interface{}) error

type LargeMap

+ func (lm *LargeMap) Remove(name interface{}) (map[interface{}]interface{}, error)

+ type MultiPolicy struct

+ MaxConcurrentNodes int

+ RecordQueueSize int

+ WaitUntilMigrationsAreOver bool

+ func NewMultiPolicy() *MultiPolicy

v1.0.1

Sep 7, 2014

Changes in this version

+ func RequestInfo(conn *Connection, names ...string) (map[string]string, error)

+ func RequestNodeInfo(node *Node, name ...string) (map[string]string, error)

+ func RequestNodeStats(node *Node) (map[string]string, error)

+ func SetCommandBufferPool(poolSize, initBufSize, maxBufferSize int)

+ type AerospikeBlob interface

+ EncodeBlob func() ([]byte, error)

+ type BasePolicy struct

+ MaxRetries int

+ Priority Priority

+ SleepBetweenRetries time.Duration

+ Timeout time.Duration

+ func NewPolicy() *BasePolicy

+ func (p *BasePolicy) GetBasePolicy() *BasePolicy

+ type BaseTask struct

+ func NewTask(cluster *Cluster, done bool) *BaseTask

+ type Bin struct

+ Name string

+ Value Value

+ func NewBin(name string, value interface{}) *Bin

+ func (bn *Bin) String() string

+ type BinMap map[string]interface

+ type BytesValue struct

+ func NewBlobValue(object AerospikeBlob) *BytesValue

+ func NewBytesValue(bytes []byte) *BytesValue

+ func (vl *BytesValue) GetObject() interface{}

+ func (vl *BytesValue) GetType() int

+ func (vl *BytesValue) String() string

+ type Client struct

+ func NewClient(hostname string, port int) (*Client, error)

+ func NewClientWithPolicy(policy *ClientPolicy, hostname string, port int) (*Client, error)

+ func NewClientWithPolicyAndHost(policy *ClientPolicy, hosts ...*Host) (*Client, error)

+ func (clnt *Client) Add(policy *WritePolicy, key *Key, bins BinMap) error

+ func (clnt *Client) AddBins(policy *WritePolicy, key *Key, bins ...*Bin) error

+ func (clnt *Client) Append(policy *WritePolicy, key *Key, bins BinMap) error

+ func (clnt *Client) AppendBins(policy *WritePolicy, key *Key, bins ...*Bin) error

+ func (clnt *Client) BatchExists(policy *BasePolicy, keys []*Key) ([]bool, error)

+ func (clnt *Client) BatchGet(policy *BasePolicy, keys []*Key, binNames ...string) ([]*Record, error)

+ func (clnt *Client) BatchGetHeader(policy *BasePolicy, keys []*Key) ([]*Record, error)

+ func (clnt *Client) Close()

+ func (clnt *Client) CreateIndex(policy *WritePolicy, namespace string, setName string, indexName string, ...) (*IndexTask, error)

+ func (clnt *Client) Delete(policy *WritePolicy, key *Key) (bool, error)

+ func (clnt *Client) DropIndex(policy *WritePolicy, namespace string, setName string, indexName string) error

+ func (clnt *Client) Execute(policy *WritePolicy, key *Key, packageName string, functionName string, ...) (interface{}, error)

+ func (clnt *Client) ExecuteUDF(policy *QueryPolicy, statement *Statement, packageName string, ...) (*ExecuteTask, error)

+ func (clnt *Client) Exists(policy *BasePolicy, key *Key) (bool, error)

+ func (clnt *Client) Get(policy *BasePolicy, key *Key, binNames ...string) (*Record, error)

+ func (clnt *Client) GetHeader(policy *BasePolicy, key *Key) (*Record, error)

+ func (clnt *Client) GetLargeList(policy *WritePolicy, key *Key, binName string, userModule string) *LargeList

+ func (clnt *Client) GetLargeMap(policy *WritePolicy, key *Key, binName string, userModule string) *LargeMap

+ func (clnt *Client) GetLargeSet(policy *WritePolicy, key *Key, binName string, userModule string) *LargeSet

+ func (clnt *Client) GetLargeStack(policy *WritePolicy, key *Key, binName string, userModule string) *LargeStack

+ func (clnt *Client) GetNodeNames() []string

+ func (clnt *Client) GetNodes() []*Node

+ func (clnt *Client) IsConnected() bool

+ func (clnt *Client) ListUDF(policy *BasePolicy) ([]*UDF, error)

+ func (clnt *Client) Operate(policy *WritePolicy, key *Key, operations ...*Operation) (*Record, error)

+ func (clnt *Client) Prepend(policy *WritePolicy, key *Key, bins BinMap) error

+ func (clnt *Client) PrependBins(policy *WritePolicy, key *Key, bins ...*Bin) error

+ func (clnt *Client) Put(policy *WritePolicy, key *Key, bins BinMap) error

+ func (clnt *Client) PutBins(policy *WritePolicy, key *Key, bins ...*Bin) error

+ func (clnt *Client) Query(policy *QueryPolicy, statement *Statement) (*Recordset, error)

+ func (clnt *Client) RegisterUDF(policy *WritePolicy, udfBody []byte, serverPath string, language Language) (*RegisterTask, error)

+ func (clnt *Client) RegisterUDFFromFile(policy *WritePolicy, clientPath string, serverPath string, language Language) (*RegisterTask, error)

+ func (clnt *Client) RemoveUDF(policy *WritePolicy, udfName string) (*RemoveTask, error)

+ func (clnt *Client) ScanAll(policy *ScanPolicy, namespace string, setName string, binNames ...string) (*Recordset, error)

+ func (clnt *Client) ScanNode(policy *ScanPolicy, node *Node, namespace string, setName string, ...) (*Recordset, error)

+ func (clnt *Client) Touch(policy *WritePolicy, key *Key) error

+ type ClientPolicy struct

+ ConnectionQueueSize int

+ FailIfNotConnected bool

+ Timeout time.Duration

+ func NewClientPolicy() *ClientPolicy

+ type Cluster struct

+ func NewCluster(policy *ClientPolicy, hosts []*Host) (*Cluster, error)

+ func (clstr *Cluster) AddSeeds(hosts []*Host)

+ func (clstr *Cluster) Close()

+ func (clstr *Cluster) FindNodeName(list []*Node, name string) bool

+ func (clstr *Cluster) GetNode(partition *Partition) (*Node, error)

+ func (clstr *Cluster) GetNodeByName(nodeName string) (*Node, error)

+ func (clstr *Cluster) GetNodes() []*Node

+ func (clstr *Cluster) GetRandomNode() (*Node, error)

+ func (clstr *Cluster) IsConnected() bool

+ func (clstr *Cluster) MigrationInProgress(timeout time.Duration) (res bool, err error)

+ func (clstr *Cluster) WaitUntillMigrationIsFinished(timeout time.Duration) (err error)

+ type Connection struct

+ func NewConnection(address string, timeout time.Duration) (*Connection, error)

+ func (ctn *Connection) Close()

+ func (ctn *Connection) IsConnected() bool

+ func (ctn *Connection) Read(buf []byte, length int) (total int, err error)

+ func (ctn *Connection) SetTimeout(timeout time.Duration) error

+ func (ctn *Connection) Write(buf []byte) (total int, err error)

+ type ExecuteTask struct

+ func NewExecuteTask(cluster *Cluster, statement *Statement) *ExecuteTask

+ func (etsk *ExecuteTask) IsDone() (bool, error)

+ func (etsk *ExecuteTask) OnComplete() chan error

+ type FieldType int

+ const DIGEST_RIPE

+ const DIGEST_RIPE_ARRAY

+ const INDEX_FILTER

+ const INDEX_LIMIT

+ const INDEX_NAME

+ const INDEX_ORDER_BY

+ const INDEX_RANGE

+ const KEY

+ const NAMESPACE

+ const QUERY_BINLIST

+ const SCAN_OPTIONS

+ const TABLE

+ const TRAN_ID

+ const UDF_ARGLIST

+ const UDF_FUNCTION

+ const UDF_OP

+ const UDF_PACKAGE_NAME

+ type Filter struct

+ func NewEqualFilter(binName string, value interface{}) *Filter

+ func NewRangeFilter(binName string, begin int64, end int64) *Filter

+ type GenerationPolicy int

+ const DUPLICATE

+ const EXPECT_GEN_EQUAL

+ const EXPECT_GEN_GT

+ const NONE

+ type Host struct

+ Name string

+ Port int

+ func NewHost(name string, port int) *Host

+ func (h *Host) String() string

+ type IndexTask struct

+ func NewIndexTask(cluster *Cluster, namespace string, indexName string) *IndexTask

+ func (tski *IndexTask) IsDone() (bool, error)

+ func (tski *IndexTask) OnComplete() chan error

+ type IndexType string

+ const NUMERIC

+ const STRING

+ type IntegerValue struct

+ func NewIntegerValue(value int) *IntegerValue

+ func (vl *IntegerValue) GetObject() interface{}

+ func (vl *IntegerValue) GetType() int

+ func (vl *IntegerValue) String() string

+ type Key struct

+ func NewKey(namespace string, setName string, key interface{}) (newKey *Key, err error)

+ func (ky *Key) Digest() []byte

+ func (ky *Key) Equals(other *Key) bool

+ func (ky *Key) Namespace() string

+ func (ky *Key) SetName() string

+ func (ky *Key) String() string

+ func (ky *Key) Value() Value

+ type Language string

+ const LUA

+ type LargeList struct

+ func NewLargeList(client *Client, policy *WritePolicy, key *Key, binName string, ...) *LargeList

+ func (ll *LargeList) Add(values ...interface{}) error

+ func (ll *LargeList) Destroy() error

+ func (ll *LargeList) Filter(filterName string, filterArgs ...interface{}) ([]interface{}, error)

+ func (ll *LargeList) Find(value interface{}) ([]interface{}, error)

+ func (ll *LargeList) FindThenFilter(value interface{}, filterName string, filterArgs ...interface{}) ([]interface{}, error)

+ func (ll *LargeList) GetCapacity() (int, error)

+ func (ll *LargeList) GetConfig() (map[interface{}]interface{}, error)

+ func (ll *LargeList) Remove(value interface{}) error

+ func (ll *LargeList) Scan() ([]interface{}, error)

+ func (ll *LargeList) SetCapacity(capacity int) error

+ func (ll *LargeList) Size() (int, error)

+ type LargeMap struct

+ func NewLargeMap(client *Client, policy *WritePolicy, key *Key, binName string, ...) *LargeMap

+ func (lm *LargeMap) Destroy() error

+ func (lm *LargeMap) Filter(filterName string, filterArgs ...interface{}) (map[interface{}]interface{}, error)

+ func (lm *LargeMap) Get(name interface{}) (map[interface{}]interface{}, error)

+ func (lm *LargeMap) GetCapacity() (int, error)

+ func (lm *LargeMap) GetConfig() (map[interface{}]interface{}, error)

+ func (lm *LargeMap) Put(name interface{}, value interface{}) error

+ func (lm *LargeMap) PutMap(theMap map[interface{}]interface{}) error

+ func (lm *LargeMap) Scan() (map[interface{}]interface{}, error)

+ func (lm *LargeMap) SetCapacity(capacity int) error

+ func (lm *LargeMap) Size() (int, error)

+ type LargeObject interface

+ Destroy func() error

+ GetCapacity func() (int, error)

+ GetConfig func() (map[interface{}]interface{}, error)

+ SetCapacity func(capacity int) error

+ Size func() (int, error)

+ type LargeSet struct

+ func NewLargeSet(client *Client, policy *WritePolicy, key *Key, binName string, ...) *LargeSet

+ func (ls *LargeSet) Add(values ...interface{}) error

+ func (ls *LargeSet) Destroy() error

+ func (ls *LargeSet) Exists(value interface{}) (bool, error)

+ func (ls *LargeSet) Filter(filterName string, filterArgs ...interface{}) ([]interface{}, error)

+ func (ls *LargeSet) Get(value interface{}) (interface{}, error)

+ func (ls *LargeSet) GetCapacity() (int, error)

+ func (ls *LargeSet) GetConfig() (map[interface{}]interface{}, error)

+ func (ls *LargeSet) Remove(value interface{}) error

+ func (ls *LargeSet) Scan() ([]interface{}, error)

+ func (ls *LargeSet) SetCapacity(capacity int) error

+ func (ls *LargeSet) Size() (int, error)

+ type LargeStack struct

+ func NewLargeStack(client *Client, policy *WritePolicy, key *Key, binName string, ...) *LargeStack

+ func (lstk *LargeStack) Destroy() error

+ func (lstk *LargeStack) Filter(peekCount int, filterName string, filterArgs ...interface{}) ([]interface{}, error)

+ func (lstk *LargeStack) GetCapacity() (int, error)

+ func (lstk *LargeStack) GetConfig() (map[interface{}]interface{}, error)

+ func (lstk *LargeStack) Peek(peekCount int) ([]interface{}, error)

+ func (lstk *LargeStack) Pop(count int) ([]interface{}, error)

+ func (lstk *LargeStack) Push(values ...interface{}) error

+ func (lstk *LargeStack) Scan() ([]interface{}, error)

+ func (lstk *LargeStack) SetCapacity(capacity int) error

+ func (lstk *LargeStack) Size() (int, error)

+ type ListValue struct

+ func NewListValue(list []interface{}) *ListValue

+ func (vl *ListValue) GetObject() interface{}

+ func (vl *ListValue) GetType() int

+ func (vl *ListValue) String() string

+ type LongValue struct

+ func NewLongValue(value int64) *LongValue

+ func (vl *LongValue) GetObject() interface{}

+ func (vl *LongValue) GetType() int

+ func (vl *LongValue) String() string

+ type MapValue struct

+ func NewMapValue(vmap map[interface{}]interface{}) *MapValue

+ func (vl *MapValue) GetObject() interface{}

+ func (vl *MapValue) GetType() int

+ func (vl *MapValue) String() string

+ type Node struct

+ func (nd *Node) AddAlias(aliasToAdd *Host)

+ func (nd *Node) Close()

+ func (nd *Node) DecreaseHealth()

+ func (nd *Node) Equals(other *Node) bool

+ func (nd *Node) GetAliases() []*Host

+ func (nd *Node) GetConnection(timeout time.Duration) (conn *Connection, err error)

+ func (nd *Node) GetHost() *Host

+ func (nd *Node) GetName() string

+ func (nd *Node) IsActive() bool

+ func (nd *Node) IsUnhealthy() bool

+ func (nd *Node) MigrationInProgress() (bool, error)

+ func (nd *Node) PutConnection(conn *Connection)

+ func (nd *Node) Refresh() ([]*Host, error)

+ func (nd *Node) RestoreHealth()

+ func (nd *Node) String() string

+ func (nd *Node) WaitUntillMigrationIsFinished(timeout time.Duration) (err error)

+ type NodeError struct

+ func (ne *NodeError) Node() *Node

+ type NullValue struct

+ func NewNullValue() *NullValue

+ func (vl *NullValue) GetObject() interface{}

+ func (vl *NullValue) GetType() int

+ func (vl *NullValue) String() string

+ type Operation struct

+ BinName *string

+ BinValue Value

+ OpType OperationType

+ func AddOp(bin *Bin) *Operation

+ func AppendOp(bin *Bin) *Operation

+ func GetHeaderOp() *Operation

+ func GetOp() *Operation

+ func GetOpForBin(binName string) *Operation

+ func PrependOp(bin *Bin) *Operation

+ func PutOp(bin *Bin) *Operation

+ func TouchOp() *Operation

+ type OperationType int

+ var ADD OperationType = 5

+ var APPEND OperationType = 9

+ var PREPEND OperationType = 10

+ var READ OperationType = 1

+ var READ_HEADER OperationType = 1

+ var TOUCH OperationType = 11

+ var WRITE OperationType = 2

+ type Partition struct

+ Namespace string

+ PartitionId int

+ func NewPartition(namespace string, partitionId int) *Partition

+ func NewPartitionByKey(key *Key) *Partition

+ func (ptn *Partition) Equals(other *Partition) bool

+ func (ptn *Partition) String() string

+ type Policy interface

+ GetBasePolicy func() *BasePolicy

+ type Priority int

+ const DEFAULT

+ const HIGH

+ const LOW

+ const MEDIUM

+ type QueryPolicy struct

+ MaxConcurrentNodes int

+ RecordQueueSize int

+ func NewQueryPolicy() *QueryPolicy

+ type Record struct

+ Bins BinMap

+ Duplicates []BinMap

+ Expiration int

+ Generation int

+ Key *Key

+ Node *Node

+ func (rc *Record) String() string

+ type RecordExistsAction int

+ const CREATE_ONLY

+ const REPLACE

+ const REPLACE_ONLY

+ const UPDATE

+ const UPDATE_ONLY

+ type Recordset struct

+ Errors chan error

+ Records chan *Record

+ func NewRecordset(size int) *Recordset

+ func (rcs *Recordset) Close()

+ func (rcs *Recordset) IsActive() bool

+ type RegisterTask struct

+ func NewRegisterTask(cluster *Cluster, packageName string) *RegisterTask

+ func (tskr *RegisterTask) IsDone() (bool, error)

+ func (tskr *RegisterTask) OnComplete() chan error

+ type RemoveTask struct

+ func NewRemoveTask(cluster *Cluster, packageName string) *RemoveTask

+ func (tskr *RemoveTask) IsDone() (bool, error)

+ func (tskr *RemoveTask) OnComplete() chan error

+ type ScanPolicy struct

+ ConcurrentNodes bool

+ FailOnClusterChange bool

+ IncludeBinData bool

+ MaxConcurrentNodes int

+ RecordQueueSize int

+ ScanPercent int

+ func NewScanPolicy() *ScanPolicy

+ type Statement struct

+ BinNames []string

+ Filters []*Filter

+ IndexName string

+ Namespace string

+ SetName string

+ TaskId int

+ func NewStatement(ns string, set string, binNames ...string) *Statement

+ func (stmt *Statement) Addfilter(filter *Filter) error

+ func (stmt *Statement) IsScan() bool

+ func (stmt *Statement) SetAggregateFunction(packageName string, functionName string, functionArgs []Value, returnData bool)

+ type StringValue struct

+ func NewStringValue(value string) *StringValue

+ func (vl *StringValue) GetObject() interface{}

+ func (vl *StringValue) GetType() int

+ func (vl *StringValue) String() string

+ type Task interface

+ IsDone func() (bool, error)

+ OnComplete func() chan error

+ type UDF struct

+ Filename string

+ Hash string

+ Language Language

+ type Value interface

+ GetObject func() interface{}

+ GetType func() int

+ String func() string

+ func NewValue(v interface{}) Value

+ type ValueArray struct

+ func NewValueArray(array []Value) *ValueArray

+ func ToValueArray(array []interface{}) *ValueArray

+ func (vl *ValueArray) GetObject() interface{}

+ func (vl *ValueArray) GetType() int

+ func (vl *ValueArray) String() string

+ type WritePolicy struct

+ Expiration int

+ Generation int

+ GenerationPolicy GenerationPolicy

+ RecordExistsAction RecordExistsAction

+ SendKey bool

+ func NewWritePolicy(generation, expiration int) *WritePolicy

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