aerospike

Aug 29, 2018

Changes in this version

+ const ListWriteFlagsNoFail

+ const ListWriteFlagsPartial

+ const MapWriteFlagsCreateOnly

+ const MapWriteFlagsDefault

+ const MapWriteFlagsNoFail

+ const MapWriteFlagsPartial

+ const MapWriteFlagsUpdateOnly

+ type AuthMode int

+ const AuthModeExternal

+ const AuthModeInternal

type ClientPolicy

+ AuthMode AuthMode

+ LoginTimeout time.Duration

+ type LoginCommand struct

+ SessionExpiration time.Time

+ SessionToken []byte

+ func NewLoginCommand(buf []byte) *LoginCommand

+ func (lcmd *LoginCommand) Login(policy *ClientPolicy, conn *Connection) error

type MapPolicy

+ func NewMapPolicyWithFlags(order mapOrderType, flags int) *MapPolicy

type MultiPolicy

+ FailOnClusterChange bool

+ ServerSocketTimeout time.Duration

Jun 11, 2018

Changes in this version

+ const ListSortFlagsDefault

+ const ListSortFlagsDropDuplicates

+ const ListWriteFlagsAddUnique

+ const ListWriteFlagsDefault

+ const ListWriteFlagsInsertBounded

type BatchPolicy

+ AllowPartialResults bool

+ type ListOrderType int

+ const ListOrderOrdered

+ const ListOrderUnordered

+ type ListPolicy struct

+ func DefaultListPolicy() *ListPolicy

+ func NewListPolicy(order ListOrderType, flags int) *ListPolicy

+ type ListReturnType int

+ const ListReturnTypeCount

+ const ListReturnTypeIndex

+ const ListReturnTypeInverted

+ const ListReturnTypeNone

+ const ListReturnTypeRank

+ const ListReturnTypeReverseIndex

+ const ListReturnTypeReverseRank

+ const ListReturnTypeValue

type Operation

+ func ListAppendWithPolicyOp(policy *ListPolicy, binName string, values ...interface{}) *Operation

+ func ListGetByIndexOp(binName string, index int, returnType ListReturnType) *Operation

+ func ListGetByIndexRangeCountOp(binName string, index, count int, returnType ListReturnType) *Operation

+ func ListGetByIndexRangeOp(binName string, index int, returnType ListReturnType) *Operation

+ func ListGetByRankOp(binName string, rank int, returnType ListReturnType) *Operation

+ func ListGetByRankRangeCountOp(binName string, rank, count int, returnType ListReturnType) *Operation

+ func ListGetByRankRangeOp(binName string, rank int, returnType ListReturnType) *Operation

+ func ListGetByValueListOp(binName string, values []interface{}, returnType ListReturnType) *Operation

+ func ListGetByValueOp(binName string, value interface{}, returnType ListReturnType) *Operation

+ func ListGetByValueRangeOp(binName string, beginValue, endValue interface{}, returnType ListReturnType) *Operation

+ func ListIncrementByOneOp(binName string, index int) *Operation

+ func ListIncrementByOneWithPolicyOp(policy *ListPolicy, binName string, index int) *Operation

+ func ListIncrementWithPolicyOp(policy *ListPolicy, binName string, index int, value interface{}) *Operation

+ func ListInsertWithPolicyOp(policy *ListPolicy, binName string, index int, values ...interface{}) *Operation

+ func ListRemoveByIndexOp(binName string, index int, returnType ListReturnType) *Operation

+ func ListRemoveByIndexRangeCountOp(binName string, index, count int, returnType ListReturnType) *Operation

+ func ListRemoveByIndexRangeOp(binName string, index, returnType ListReturnType) *Operation

+ func ListRemoveByRankOp(binName string, rank int, returnType ListReturnType) *Operation

+ func ListRemoveByRankRangeCountOp(binName string, rank int, count int, returnType ListReturnType) *Operation

+ func ListRemoveByRankRangeOp(binName string, rank int, returnType ListReturnType) *Operation

+ func ListRemoveByValueListOp(binName string, values []interface{}, returnType ListReturnType) *Operation

+ func ListRemoveByValueOp(binName string, value interface{}, returnType ListReturnType) *Operation

+ func ListRemoveByValueRangeOp(binName string, returnType ListReturnType, valueBegin, valueEnd interface{}) *Operation

+ func ListSetOrderOp(binName string, listOrder ListOrderType) *Operation

+ func ListSortOp(binName string, sortFlags int) *Operation

+ func MapGetByKeyListOp(binName string, keys []interface{}, returnType mapReturnType) *Operation

+ func MapGetByValueListOp(binName string, values []interface{}, returnType mapReturnType) *Operation

Mar 15, 2018

Changes in this version

+ const DefaultBufferSize

type BasePolicy

+ LinearizeRead bool

+ SendKey bool

+ type Partitions struct

+ CPMode bool

+ Replicas [][]*Node

Nov 29, 2017

Changes in this version

+ type BatchPolicy struct

+ AllowInline bool

+ ConcurrentNodes int

+ SendSetName bool

+ UseBatchDirect bool

+ func NewBatchPolicy() *BatchPolicy

+ type BatchRead struct

+ BinNames []string

+ Key *Key

+ ReadAllBins bool

+ Record *Record

+ func NewBatchRead(key *Key, binNames []string) *BatchRead

+ func NewBatchReadHeader(key *Key) *BatchRead

+ func (br *BatchRead) String() string

type Client

+ DefaultBatchPolicy *BatchPolicy

+ func (clnt *Client) BatchGetComplex(policy *BatchPolicy, records []*BatchRead) error

type FieldType

+ const BATCH_INDEX

+ const BATCH_INDEX_WITH_SET

Oct 12, 2017

Changes in this version

type Client

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

Sep 5, 2017

Changes in this version

type Operation

+ func ListIncrementOp(binName string, index int, value interface{}) *Operation

+ type PredExp interface

+ String func() string

type ReplicaPolicy

+ const SEQUENCE

Aug 17, 2017

Changes in this version

type BasePolicy

+ SocketTimeout time.Duration

type Client

+ func (clnt *Client) Stats() (map[string]interface{}, error)

type MultiPolicy

+ IncludeBinData bool

Apr 25, 2017

Changes in this version

type BasePolicy

+ SleepMultiplier float64

type Client

+ func (clnt *Client) BatchGetObjects(policy *BasePolicy, keys []*Key, objects []interface{}) (found []bool, err error)

+ type OperationSubType *int

Apr 5, 2017

Changes in this version

+ func NewPredExpAnd(nexpr uint16) *predExpAnd

+ func NewPredExpGeoJSONBin(name string) *predExpBin

+ func NewPredExpGeoJSONContains() *predExpCompare

+ func NewPredExpGeoJSONValue(val string) *predExpGeoJSONValue

+ func NewPredExpGeoJSONVar(name string) *predExpVar

+ func NewPredExpGeoJSONWithin() *predExpCompare

+ func NewPredExpIntegerBin(name string) *predExpBin

+ func NewPredExpIntegerEqual() *predExpCompare

+ func NewPredExpIntegerGreater() *predExpCompare

+ func NewPredExpIntegerGreaterEq() *predExpCompare

+ func NewPredExpIntegerLess() *predExpCompare

+ func NewPredExpIntegerLessEq() *predExpCompare

+ func NewPredExpIntegerUnequal() *predExpCompare

+ func NewPredExpIntegerValue(val int64) *predExpIntegerValue

+ func NewPredExpIntegerVar(name string) *predExpVar

+ func NewPredExpListBin(name string) *predExpBin

+ func NewPredExpListIterateAnd(name string) *predExpIter

+ func NewPredExpListIterateOr(name string) *predExpIter

+ func NewPredExpMapBin(name string) *predExpBin

+ func NewPredExpMapKeyIterateAnd(name string) *predExpIter

+ func NewPredExpMapKeyIterateOr(name string) *predExpIter

+ func NewPredExpMapValIterateAnd(name string) *predExpIter

+ func NewPredExpMapValIterateOr(name string) *predExpIter

+ func NewPredExpNot() *predExpNot

+ func NewPredExpOr(nexpr uint16) *predExpOr

+ func NewPredExpRecDeviceSize() *predExpMD

+ func NewPredExpRecDigestModulo(mod int32) *predExpMDDigestModulo

+ func NewPredExpRecLastUpdate() *predExpMD

+ func NewPredExpRecVoidTime() *predExpMD

+ func NewPredExpStringBin(name string) *predExpBin

+ func NewPredExpStringEqual() *predExpCompare

+ func NewPredExpStringRegex(cflags uint32) *predExpStringRegex

+ func NewPredExpStringUnequal() *predExpCompare

+ func NewPredExpStringValue(val string) *predExpStringValue

+ func NewPredExpStringVar(name string) *predExpVar

+ func NewPredExpUnknownBin(name string) *predExpBin

type Client

+ func (clnt *Client) Truncate(policy *WritePolicy, namespace, set string, beforeLastUpdate *time.Time) error

type ClientPolicy

+ IgnoreOtherSubnetAliases bool

type FieldType

+ const PREDEXP

+ const SCAN_TIMEOUT

type ScanPolicy

+ ServerSocketTimeout time.Duration

type Statement

+ func (stmt *Statement) SetPredExp(predexp ...predExp) error

Mar 1, 2017

Changes in this version

type Key

+ func (ky *Key) SetValue(val Value) error

Jan 11, 2017

Changes in this version

+ const DataAdmin

type Client

+ func (clnt *Client) CreateRole(policy *AdminPolicy, roleName string, privileges []Privilege) error

+ func (clnt *Client) DropRole(policy *AdminPolicy, roleName string) error

+ func (clnt *Client) GrantPrivileges(policy *AdminPolicy, roleName string, privileges []Privilege) error

+ func (clnt *Client) QueryRole(policy *AdminPolicy, role string) (*Role, error)

+ func (clnt *Client) QueryRoles(policy *AdminPolicy) ([]*Role, error)

+ func (clnt *Client) RevokePrivileges(policy *AdminPolicy, roleName string, privileges []Privilege) error

type NodeError

+ func (ne *NodeError) Err() error

+ type Privilege struct

+ Code privilegeCode

+ Namespace string

+ SetName string

type Role

+ Name string

+ Privileges []Privilege

Dec 20, 2016

Changes in this version

+ func PackBool(cmd BufferEx, val bool) (int, error)

+ func PackBytes(cmd BufferEx, b []byte) (int, error)

+ func PackFloat32(cmd BufferEx, val float32) (int, error)

+ func PackFloat64(cmd BufferEx, val float64) (int, error)

+ func PackInt64(cmd BufferEx, val int64) (int, error)

+ func PackJson(cmd BufferEx, theMap map[string]interface{}) (int, error)

+ func PackList(cmd BufferEx, list ListIter) (int, error)

+ func PackMap(cmd BufferEx, theMap MapIter) (int, error)

+ func PackNil(cmd BufferEx) (int, error)

+ func PackString(cmd BufferEx, val string) (int, error)

+ func PackUInt64(cmd BufferEx, val uint64) (int, error)

+ type BufferEx interface

+ Write func(b []byte) (int, error)

+ WriteByte func(b byte) (int, error)

+ WriteFloat32 func(float float32) (int, error)

+ WriteFloat64 func(float float64) (int, error)

+ WriteInt16 func(num int16) (int, error)

+ WriteInt32 func(num int32) (int, error)

+ WriteInt64 func(num int64) (int, error)

+ WriteString func(s string) (int, error)

+ WriteUint16 func(num uint16) (int, error)

+ WriteUint32 func(num uint32) (int, error)

+ WriteUint64 func(num uint64) (int, error)

type Client

+ func (clnt *Client) Cluster() *Cluster

type Cluster

+ func (clstr *Cluster) GetAliases() map[Host]*Node

+ func (clstr *Cluster) GetSeeds() []Host

type ListIter

+ PackList func(buf BufferEx) (int, error)

type MapIter

+ PackMap func(buf BufferEx) (int, error)

Nov 16, 2016

Changes in this version

+ const TTLDontExpire

+ const TTLDontUpdate

+ const TTLServerDefault

Oct 25, 2016

Changes in this version

+ func SetAerospikeTag(tag string)

+ type JsonValue map[string]interface

+ func (vl JsonValue) GetObject() interface{}

+ func (vl JsonValue) GetType() int

+ func (vl JsonValue) String() string

+ func NewJsonValue(vmap map[string]interface{}) JsonValue

+ type ListIter interface

+ Len func() int

+ Range func(func(interface{}) error) error

+ type ListerValue struct

+ func NewListerValue(list ListIter) *ListerValue

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

+ func (vl *ListerValue) GetType() int

+ func (vl *ListerValue) String() string

+ type MapIter interface

+ Len func() int

+ Range func(func(interface{}, interface{}) error) error

+ type MapperValue struct

+ func NewMapperValue(vmap MapIter) *MapperValue

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

+ func (vl *MapperValue) GetType() int

+ func (vl *MapperValue) String() string

Oct 14, 2016

Changes in this version

type ClientPolicy

+ ClusterName string

+ TlsConfig *tls.Config

type Connection

+ func NewSecureConnection(policy *ClientPolicy, host *Host) (*Connection, error)

type Host

+ TLSName string

Aug 19, 2016

Changes in this version

type WritePolicy

+ DurableDelete bool

Jul 27, 2016

Changes in this version

type Recordset

+ func (os *Recordset) TaskId() uint64

Jul 19, 2016

Changes in this version

type BasePolicy

+ ReplicaPolicy ReplicaPolicy

type ClientPolicy

+ RequestProleReplicas bool

+ type DropIndexTask struct

+ func NewDropIndexTask(cluster *Cluster, namespace string, indexName string) *DropIndexTask

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

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

+ type ReplicaPolicy int

+ const MASTER

+ const MASTER_PROLES

+ const RANDOM

Jun 2, 2016

Changes in this version

+ var MapOrder = struct{ ... }

+ var MapReturnType = struct{ ... }

+ var MapWriteMode = struct{ ... }

+ type MapPair struct

+ Key interface{}

+ Value interface{}

+ type MapPolicy struct

+ func DefaultMapPolicy() *MapPolicy

+ func NewMapPolicy(order mapOrderType, writeMode *mapWriteMode) *MapPolicy

type Operation

+ func MapClearOp(binName string) *Operation

+ func MapDecrementOp(policy *MapPolicy, binName string, key interface{}, decr interface{}) *Operation

+ func MapGetByIndexOp(binName string, index int, returnType mapReturnType) *Operation

+ func MapGetByIndexRangeCountOp(binName string, index int, count int, returnType mapReturnType) *Operation

+ func MapGetByIndexRangeOp(binName string, index int, returnType mapReturnType) *Operation

+ func MapGetByKeyOp(binName string, key interface{}, returnType mapReturnType) *Operation

+ func MapGetByKeyRangeOp(binName string, keyBegin interface{}, keyEnd interface{}, ...) *Operation

+ func MapGetByRankOp(binName string, rank int, returnType mapReturnType) *Operation

+ func MapGetByRankRangeCountOp(binName string, rank int, count int, returnType mapReturnType) *Operation

+ func MapGetByRankRangeOp(binName string, rank int, returnType mapReturnType) *Operation

+ func MapGetByValueOp(binName string, value interface{}, returnType mapReturnType) *Operation

+ func MapGetByValueRangeOp(binName string, valueBegin interface{}, valueEnd interface{}, ...) *Operation

+ func MapIncrementOp(policy *MapPolicy, binName string, key interface{}, incr interface{}) *Operation

+ func MapPutItemsOp(policy *MapPolicy, binName string, amap map[interface{}]interface{}) *Operation

+ func MapPutOp(policy *MapPolicy, binName string, key interface{}, value interface{}) *Operation

+ func MapRemoveByIndexOp(binName string, index int, returnType mapReturnType) *Operation

+ func MapRemoveByIndexRangeCountOp(binName string, index int, count int, returnType mapReturnType) *Operation

+ func MapRemoveByIndexRangeOp(binName string, index int, returnType mapReturnType) *Operation

+ func MapRemoveByKeyListOp(binName string, keys []interface{}, returnType mapReturnType) *Operation

+ func MapRemoveByKeyOp(binName string, key interface{}, returnType mapReturnType) *Operation

+ func MapRemoveByKeyRangeOp(binName string, keyBegin interface{}, keyEnd interface{}, ...) *Operation

+ func MapRemoveByRankOp(binName string, rank int, returnType mapReturnType) *Operation

+ func MapRemoveByRankRangeCountOp(binName string, rank int, count int, returnType mapReturnType) *Operation

+ func MapRemoveByRankRangeOp(binName string, rank int, returnType mapReturnType) *Operation

+ func MapRemoveByValueListOp(binName string, values []interface{}, returnType mapReturnType) *Operation

+ func MapRemoveByValueOp(binName string, value interface{}, returnType mapReturnType) *Operation

+ func MapRemoveByValueRangeOp(binName string, valueBegin interface{}, valueEnd interface{}, ...) *Operation

+ func MapSetPolicyOp(policy *MapPolicy, binName string) *Operation

+ func MapSizeOp(binName string) *Operation

type OperationType

+ var MAP_MODIFY OperationType = &struct{ ... }{ ... }

+ var MAP_READ OperationType = &struct{ ... }{ ... }

May 16, 2016

Changes in this version

type Recordset

+ func (rcs *Recordset) Read() (record *Record, err error)

Apr 1, 2016

Changes in this version

type Filter

+ func NewGeoRegionsContainingPointForCollectionFilter(binName string, collectionType IndexCollectionType, point string) *Filter

+ func NewGeoWithinRadiusForCollectionFilter(binName string, collectionType IndexCollectionType, lng, lat, radius float64) *Filter

+ func NewGeoWithinRegionForCollectionFilter(binName string, collectionType IndexCollectionType, region string) *Filter

Mar 8, 2016

Changes in this version

type Node

+ func (nd *Node) RequestInfo(name ...string) (map[string]string, error)

Feb 9, 2016

Changes in this version

type Client

+ func (clnt *Client) String() string

type ClientPolicy

+ UseServicesAlternate bool

type Cluster

+ func (clstr *Cluster) String() string

type Operation

+ func ListGetRangeFromOp(binName string, index int) *Operation

+ func ListPopRangeFromOp(binName string, index int) *Operation

+ func ListRemoveRangeFromOp(binName string, index int) *Operation

type Result

+ func (res *Result) String() string

Jan 13, 2016

Changes in this version

+ func SetLuaPath(lpath string)

type Client

+ func (clnt *Client) QueryAggregate(policy *QueryPolicy, statement *Statement, packageName, functionName string, ...) (*Recordset, error)

type Connection

+ func (ctn *Connection) ReadN(buf io.Writer, length int64) (total int64, err error)

Dec 14, 2015

Changes in this version

type Filter

+ func NewGeoRegionsContainingPointFilter(binName, point string) *Filter

+ func NewGeoWithinRadiusFilter(binName string, lng, lat, radius float64) *Filter

+ func NewGeoWithinRegionFilter(binName, region string) *Filter

type Operation

+ func ListAppendOp(binName string, values ...interface{}) *Operation

+ func ListClearOp(binName string) *Operation

+ func ListGetOp(binName string, index int) *Operation

+ func ListGetRangeOp(binName string, index int, count int) *Operation

+ func ListInsertOp(binName string, index int, values ...interface{}) *Operation

+ func ListPopOp(binName string, index int) *Operation

+ func ListPopRangeOp(binName string, index int, count int) *Operation

+ func ListRemoveOp(binName string, index int) *Operation

+ func ListRemoveRangeOp(binName string, index int, count int) *Operation

+ func ListSetOp(binName string, index int, value interface{}) *Operation

+ func ListSizeOp(binName string) *Operation

+ func ListTrimOp(binName string, index int, count int) *Operation

type OperationType

+ const CDT_MODIFY

+ const CDT_READ

type Value

+ func ToValueSlice(array []interface{}) []Value

type WritePolicy

+ RespondPerEachOp bool

Dec 1, 2015

Changes in this version

type Client

+ func (clnt *Client) QueryNodeObjects(policy *QueryPolicy, node *Node, statement *Statement, objChan interface{}) (*Recordset, error)

+ func (clnt *Client) QueryObjects(policy *QueryPolicy, statement *Statement, objChan interface{}) (*Recordset, error)

+ func (clnt *Client) ScanAllObjects(apolicy *ScanPolicy, objChan interface{}, namespace string, setName string, ...) (*Recordset, error)

+ func (clnt *Client) ScanNodeObjects(apolicy *ScanPolicy, node *Node, objChan interface{}, namespace string, ...) (*Recordset, error)

type LargeList

+ func (ll *LargeList) Exist(values ...interface{}) ([]bool, error)

type ScanPolicy

+ IncludeLDT bool

Oct 16, 2015

Changes in this version

type Client

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

type ClientPolicy

+ IpMap map[string]string

type FieldType

+ const INDEX_TYPE

type Filter

+ func NewContainsFilter(name string, indexCollectionType IndexCollectionType, value interface{}) *Filter

+ func NewContainsRangeFilter(name string, indexCollectionType IndexCollectionType, begin, end int64) *Filter

+ func NewGeoPointsWithinRegionFilter(name, region string) *Filter

+ func NewGeoRegionContainingPointFilter(name, point string) *Filter

+ func (fltr *Filter) IndexCollectionType() IndexCollectionType

+ type FloatValue float64

+ func NewFloatValue(value float64) FloatValue

+ func (vl FloatValue) GetObject() interface{}

+ func (vl FloatValue) GetType() int

+ func (vl FloatValue) String() string

+ type GeoJSONValue string

+ func NewGeoJSONValue(value string) GeoJSONValue

+ func (vl GeoJSONValue) GetObject() interface{}

+ func (vl GeoJSONValue) GetType() int

+ func (vl GeoJSONValue) String() string

+ type IndexCollectionType int

+ const ICT_DEFAULT

+ const ICT_LIST

+ const ICT_MAPKEYS

+ const ICT_MAPVALUES

type IndexType

+ const GEO2DSPHERE

type Role

+ const ReadWriteUDF

Aug 28, 2015

Changes in this version

+ var MaxBufferSize = 1024 * 1024 * 10

May 30, 2015

Changes in this version

type LargeList

+ func (ll *LargeList) FFilterThenindFirst(count int, filterModule, filterName string, filterArgs ...interface{}) ([]interface{}, error)

+ func (ll *LargeList) FilterThenFindFrom(begin interface{}, count int, filterModule, filterName string, ...) ([]interface{}, error)

+ func (ll *LargeList) FilterThenFindLast(count int, filterModule, filterName string, filterArgs ...interface{}) ([]interface{}, error)

+ func (ll *LargeList) FindFirst(count int) ([]interface{}, error)

+ func (ll *LargeList) FindFrom(begin interface{}, count int) ([]interface{}, error)

+ func (ll *LargeList) FindLast(count int) ([]interface{}, error)

+ func (ll *LargeList) RangeN(begin, end interface{}, count int) ([]interface{}, error)

+ func (ll *LargeList) RangeNThenFilter(begin, end interface{}, count int, filterModule string, filterName string, ...) ([]interface{}, error)

+ func (ll *LargeList) SetPageSize(pageSize int) error

type Node

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

+ type Result struct

+ Err error

+ Record *Record

May 15, 2015

Changes in this version

type ClientPolicy

+ IdleTimeout time.Duration

type Cluster

+ func (clstr *Cluster) ClientPolicy() (res ClientPolicy)

+ func (clstr *Cluster) Password() (res []byte)

Apr 13, 2015

Changes in this version

type ClientPolicy

+ LimitConnectionsToQueueSize bool

type Connection

+ func (ctn *Connection) Authenticate(user string, password []byte) error

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

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

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

Nov 28, 2014

Changes in this version

type Client

+ DefaultPolicy *BasePolicy

+ DefaultQueryPolicy *QueryPolicy

+ DefaultScanPolicy *ScanPolicy

+ DefaultWritePolicy *WritePolicy

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

Sep 7, 2014

Changes in this version

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

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

type Client

+ 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) CreateIndex(policy *WritePolicy, namespace string, setName string, indexName string, ...) (*IndexTask, 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) 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) ListUDF(policy *BasePolicy) ([]*UDF, error)

+ func (clnt *Client) Operate(policy *WritePolicy, key *Key, operations ...*Operation) (*Record, 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)

type Cluster

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

+ func (clstr *Cluster) WaitUntillMigrationIsFinished(timeout time.Duration) (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 Filter struct

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

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

+ 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 Key

+ 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 Node

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

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

+ type NodeError struct

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

type NullValue

+ func NewNullValue() *NullValue

type Operation

+ 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 QueryPolicy

+ func NewQueryPolicy() *QueryPolicy

type Record

+ Key *Key

+ Node *Node

+ 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

+ RecordQueueSize 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 Task interface

+ IsDone func() (bool, error)

+ OnComplete func() chan error

+ type UDF struct

+ Filename string

+ Hash string

+ Language Language

type ValueArray

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

type WritePolicy

+ SendKey bool

Aug 12, 2014

Changes in this version

+ const AS_MSG_TYPE

+ const CL_MSG_VERSION

+ const DIGEST_SIZE

+ const FIELD_HEADER_SIZE

+ const INFO1_GET_ALL

+ const INFO1_NOBINDATA

+ const INFO1_READ

+ const INFO2_CREATE_ONLY

+ const INFO2_DELETE

+ const INFO2_GENERATION

+ const INFO2_GENERATION_DUP

+ const INFO2_GENERATION_GT

+ const INFO2_WRITE

+ const INFO3_CREATE_OR_REPLACE

+ const INFO3_LAST

+ const INFO3_REPLACE_ONLY

+ const INFO3_UPDATE_ONLY

+ const MSG_REMAINING_HEADER_SIZE

+ const MSG_TOTAL_HEADER_SIZE

+ const OPERATION_HEADER_SIZE

+ func BytesToParticle(ptype int, buf []byte, offset int, length int) (interface{}, error)

+ func ComputeDigest(setName string, key Value) ([]byte, error)

+ func PackAnyArray(val []interface{}) ([]byte, error)

+ func PackAnyMap(val map[interface{}]interface{}) ([]byte, error)

+ func PackValueArray(val []Value) ([]byte, error)

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

+ func RequestInfoForHostName(hostname string, port int, names ...string) map[string]string

+ func RequestInfoForNode(node Node, name ...string) (string, error)

+ type AerospikeBlob interface

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

+ type BaseCommand struct

+ func (this *BaseCommand) SetDelete(policy *WritePolicy, key *Key)

+ func (this *BaseCommand) SetExists(key *Key)

+ func (this *BaseCommand) SetOperate(policy *WritePolicy, key *Key, operations []*Operation) error

+ func (this *BaseCommand) SetRead(key *Key, binNames []string)

+ func (this *BaseCommand) SetReadForKeyOnly(key *Key)

+ func (this *BaseCommand) SetReadHeader(key *Key)

+ func (this *BaseCommand) SetScan(policy *ScanPolicy, namespace *string, setName *string, binNames []string)

+ func (this *BaseCommand) SetTouch(policy *WritePolicy, key *Key)

+ func (this *BaseCommand) SetWrite(policy *WritePolicy, operation OperationType, key *Key, bins []*Bin) error

+ func (this *BaseCommand) WriteFieldBytes(bytes []byte, ftype FieldType)

+ func (this *BaseCommand) WriteFieldHeader(size int, ftype FieldType)

+ func (this *BaseCommand) WriteFieldString(str string, ftype FieldType)

+ type BasePolicy struct

+ MaxRetries int

+ Priority Priority

+ SleepBetweenRetries time.Duration

+ Timeout time.Duration

+ func NewPolicy() *BasePolicy

+ func (this *BasePolicy) GetBasePolicy() *BasePolicy

+ type Bin struct

+ Name string

+ Value Value

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

+ func (this *Bin) String() string

+ type BinMap map[string]interface

+ type BytesValue struct

+ func NewBlobValue(object AerospikeBlob) *BytesValue

+ func NewBytesValue(bytes []byte) *BytesValue

+ func (this *BytesValue) EstimateSize() int

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

+ func (this *BytesValue) GetType() int

+ func (this *BytesValue) Pack(packer *Packer) error

+ func (this *BytesValue) String() string

+ func (this *BytesValue) Write(buffer []byte, offset int) (int, error)

+ 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 (this *Client) Add(policy *WritePolicy, key *Key, bins BinMap) error

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

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

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

+ func (this *Client) Close()

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

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

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

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

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

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

+ func (this *Client) IsConnected() bool

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

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

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

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

+ func (this *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 (this *Cluster) AddSeeds(hosts []*Host)

+ func (this *Cluster) Close()

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

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

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

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

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

+ func (this *Cluster) IsConnected() bool

+ type Command interface

+ Execute func() error

+ type Connection struct

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

+ func (this *Connection) Close()

+ func (this *Connection) IsConnected() bool

+ func (this *Connection) Read(buf []byte, length int) (int, error)

+ func (this *Connection) SetTimeout(timeout time.Duration)

+ func (this *Connection) Write(buf []byte) (int, error)

+ type DeleteCommand struct

+ func NewDeleteCommand(cluster *Cluster, policy *WritePolicy, key *Key) *DeleteCommand

+ func (this *DeleteCommand) Execute() error

+ func (this *DeleteCommand) Existed() bool

+ type ExistsCommand struct

+ func NewExistsCommand(cluster *Cluster, policy Policy, key *Key) *ExistsCommand

+ func (this *ExistsCommand) Execute() error

+ func (this *ExistsCommand) Exists() bool

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

+ func NewInfo(conn *Connection, commands ...string) (*Info, error)

+ func (this *Info) GetValue() string

+ type IntegerValue struct

+ func NewIntegerValue(value int) *IntegerValue

+ func (this *IntegerValue) EstimateSize() int

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

+ func (this *IntegerValue) GetType() int

+ func (this *IntegerValue) Pack(packer *Packer) error

+ func (this *IntegerValue) String() string

+ func (this *IntegerValue) Write(buffer []byte, offset int) (int, error)

+ type Key struct

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

+ func NewKeyByDigest(namespace string, setName string, digest [20]byte) *Key

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

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

+ func (this *Key) Namespace() *string

+ func (this *Key) SetName() *string

+ type ListValue struct

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

+ func (this *ListValue) EstimateSize() int

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

+ func (this *ListValue) GetType() int

+ func (this *ListValue) Pack(packer *Packer) error

+ func (this *ListValue) String() string

+ func (this *ListValue) Write(buffer []byte, offset int) (int, error)

+ type LongValue struct

+ func NewLongValue(value int64) *LongValue

+ func (this *LongValue) EstimateSize() int

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

+ func (this *LongValue) GetType() int

+ func (this *LongValue) Pack(packer *Packer) error

+ func (this *LongValue) String() string

+ func (this *LongValue) Write(buffer []byte, offset int) (int, error)

+ type MapValue struct

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

+ func (this *MapValue) EstimateSize() int

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

+ func (this *MapValue) GetType() int

+ func (this *MapValue) Pack(packer *Packer) error

+ func (this *MapValue) String() string

+ func (this *MapValue) Write(buffer []byte, offset int) (int, error)

+ type Node struct

+ func NewNode(cluster *Cluster, nv *NodeValidator) *Node

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

+ func (this *Node) Close()

+ func (this *Node) DecreaseHealth()

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

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

+ func (this *Node) GetConnection(timeout time.Duration) (*Connection, error)

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

+ func (this *Node) GetName() string

+ func (this *Node) IsActive() bool

+ func (this *Node) IsUnhealthy() bool

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

+ func (this *Node) Refresh(friends []*Host) error

+ func (this *Node) RestoreHealth()

+ func (this *Node) String() string

+ type NodeValidator struct

+ func NewNodeValidator(host *Host, timeout time.Duration) (*NodeValidator, error)

+ type NullValue struct

+ func (this *NullValue) EstimateSize() int

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

+ func (this *NullValue) GetType() int

+ func (this *NullValue) Pack(packer *Packer) error

+ func (this *NullValue) String() string

+ func (this *NullValue) Write(buffer []byte, offset int) (int, error)

+ type Operation struct

+ BinName *string

+ BinValue Value

+ OpType OperationType

+ func NewAddOp(bin Bin) *Operation

+ func NewAppendOp(bin Bin) *Operation

+ func NewGetHeaderOp() *Operation

+ func NewGetOp() *Operation

+ func NewGetOpByBinName(binName string) *Operation

+ func NewPrependOp(bin Bin) *Operation

+ func NewPutOp(bin Bin) *Operation

+ func NewTouchOp() *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 Packer struct

+ func NewPacker() *Packer

+ func (this *Packer) PackAByte(val byte)

+ func (this *Packer) PackAInt(val int)

+ func (this *Packer) PackALong(val int64)

+ func (this *Packer) PackArrayBegin(size int)

+ func (this *Packer) PackByte(valType int, val byte)

+ func (this *Packer) PackByteArray(src []byte, srcOffset int, srcLength int)

+ func (this *Packer) PackByteArrayBegin(length int)

+ func (this *Packer) PackBytes(b []byte)

+ func (this *Packer) PackInt(valType int, val int32)

+ func (this *Packer) PackList(list []interface{}) error

+ func (this *Packer) PackLong(valType int, val int64)

+ func (this *Packer) PackMap(theMap map[interface{}]interface{}) error

+ func (this *Packer) PackMapBegin(size int)

+ func (this *Packer) PackNil()

+ func (this *Packer) PackObject(obj interface{}) error

+ func (this *Packer) PackShort(valType int, val int16)

+ func (this *Packer) PackString(val string)

+ func (this *Packer) PackValueArray(values []Value) error

+ type Partition struct

+ Namespace string

+ PartitionId int

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

+ func NewPartitionByKey(key *Key) *Partition

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

+ func (this *Partition) String() string

+ type PartitionTokenizer interface

+ UpdatePartition func(nmap map[string]atomicNodeArray, node *Node) map[string]atomicNodeArray

+ type PartitionTokenizerNew struct

+ func NewPartitionTokenizerNew(conn *Connection) (*PartitionTokenizerNew, error)

+ func (this *PartitionTokenizerNew) UpdatePartition(nmap map[string]atomicNodeArray, node *Node) map[string]atomicNodeArray

+ type PartitionTokenizerOld struct

+ func NewPartitionTokenizerOld(conn *Connection) (*PartitionTokenizerOld, error)

+ func (this *PartitionTokenizerOld) UpdatePartition(hmap map[string]atomicNodeArray, node *Node) map[string]atomicNodeArray

+ type Policy interface

+ GetBasePolicy func() *BasePolicy

+ type Priority int

+ const DEFAULT

+ const HIGH

+ const LOW

+ const MEDIUM

+ type QueryPolicy struct

+ MaxConcurrentNodes int

+ RecordQueueSize int

+ type ReadCommand struct

+ func NewReadCommand(cluster *Cluster, policy Policy, key *Key, binNames []string) *ReadCommand

+ func (this *ReadCommand) Execute() error

+ func (this *ReadCommand) GetRecord() *Record

+ type ReadHeaderCommand struct

+ func NewReadHeaderCommand(cluster *Cluster, policy Policy, key *Key) *ReadHeaderCommand

+ func (this *ReadHeaderCommand) Execute() error

+ func (this *ReadHeaderCommand) GetRecord() *Record

+ type Record struct

+ Bins BinMap

+ Duplicates []BinMap

+ Expiration int

+ Generation int

+ func NewRecord(bins BinMap, duplicates []BinMap, generation int, expiration int) *Record

+ func (this *Record) String() string

+ type RecordExistsAction int

+ const CREATE_ONLY

+ const REPLACE

+ const REPLACE_ONLY

+ const UPDATE

+ const UPDATE_ONLY

+ type ScanPolicy struct

+ ConcurrentNodes bool

+ FailOnClusterChange bool

+ IncludeBinData bool

+ MaxConcurrentNodes int

+ ScanPercent int

+ type SingleCommand struct

+ func NewSingleCommand(cluster *Cluster, key *Key) *SingleCommand

+ type StringValue struct

+ func NewStringValue(value string) *StringValue

+ func (this *StringValue) EstimateSize() int

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

+ func (this *StringValue) GetType() int

+ func (this *StringValue) Pack(packer *Packer) error

+ func (this *StringValue) String() string

+ func (this *StringValue) Write(buffer []byte, offset int) (int, error)

+ type TouchCommand struct

+ func NewTouchCommand(cluster *Cluster, policy *WritePolicy, key *Key) *TouchCommand

+ func (this *TouchCommand) Execute() error

+ type Unpacker struct

+ func NewUnpacker(buffer []byte, offset int, length int) *Unpacker

+ func (this *Unpacker) UnpackList() ([]interface{}, error)

+ func (this *Unpacker) UnpackMap() (map[interface{}]interface{}, error)

+ type Value interface

+ EstimateSize func() int

+ GetObject func() interface{}

+ GetType func() int

+ Pack func(packer *Packer) error

+ String func() string

+ Write func(buffer []byte, offset int) (int, error)

+ func NewValue(v interface{}) Value

+ type ValueArray struct

+ func NewValueArray(array []Value) *ValueArray

+ func (this *ValueArray) EstimateSize() int

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

+ func (this *ValueArray) GetType() int

+ func (this *ValueArray) Pack(packer *Packer) error

+ func (this *ValueArray) String() string

+ func (this *ValueArray) Write(buffer []byte, offset int) (int, error)

+ type WriteCommand struct

+ func NewWriteCommand(cluster *Cluster, policy *WritePolicy, key *Key, bins []*Bin, ...) *WriteCommand

+ func (this *WriteCommand) Execute() error

+ type WritePolicy struct

+ Expiration int

+ Generation int

+ GenerationPolicy GenerationPolicy

+ RecordExistsAction RecordExistsAction

+ func NewWritePolicy(generation, expiration int) *WritePolicy