Documentation ¶
Overview ¶
Package aerospike provides a client to connect and interact with an Aerospike cluster.
Copyright 2012-2019 Aerospike, Inc. *
Portions may be licensed to Aerospike, Inc. under one or more contributor
license agreements WHICH ARE COMPATIBLE WITH THE APACHE LICENSE, VERSION 2.0. *
Licensed under the Apache License, Version 2.0 (the "License"); you may not
use this file except in compliance with the License. You may obtain a copy of
the License at http://www.apache.org/licenses/LICENSE-2.0 *
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
Copyright 2012-2019 Aerospike, Inc. *
Portions may be licensed to Aerospike, Inc. under one or more contributor
license agreements WHICH ARE COMPATIBLE WITH THE APACHE LICENSE, VERSION 2.0. *
Licensed under the Apache License, Version 2.0 (the "License"); you may not
use this file except in compliance with the License. You may obtain a copy of
the License at http: *www.apache.org/licenses/LICENSE-2.0 *
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
Copyright 2012-2019 Aerospike, Inc. *
Portions may be licensed to Aerospike, Inc. under one or more contributor
license agreements WHICH ARE COMPATIBLE WITH THE APACHE LICENSE, VERSION 2.0. *
Licensed under the Apache License, Version 2.0 (the "License"); you may not
use this file except in compliance with the License. You may obtain a copy of
the License at http://www.apache.org/licenses/LICENSE-2.0 *
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
Index ¶
- Constants
- Variables
- 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
- 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)
- func RequestInfo(conn *Connection, names ...string) (map[string]string, error)
- func SetAerospikeTag(tag string)
- func SetLuaPath(lpath string)
- type AdminPolicy
- type AerospikeBlob
- type AuthMode
- type BasePolicy
- type BatchError
- type BatchPolicy
- type BatchRead
- type Bin
- type BinMap
- type BitOverflowAction
- type BitPolicy
- type BufferEx
- type BytesValue
- type CDTContext
- func CtxListIndex(index int) *CDTContext
- func CtxListIndexCreate(index int, order ListOrderType, pad bool) *CDTContext
- func CtxListRank(rank int) *CDTContext
- func CtxListValue(key Value) *CDTContext
- func CtxMapIndex(index int) *CDTContext
- func CtxMapKey(key Value) *CDTContext
- func CtxMapKeyCreate(key Value, order mapOrderType) *CDTContext
- func CtxMapRank(rank int) *CDTContext
- func CtxMapValue(key Value) *CDTContext
- type Client
- func (clnt *Client) Add(policy *WritePolicy, key *Key, binMap BinMap) error
- func (clnt *Client) AddBins(policy *WritePolicy, key *Key, bins ...*Bin) error
- func (clnt *Client) Append(policy *WritePolicy, key *Key, binMap BinMap) error
- func (clnt *Client) AppendBins(policy *WritePolicy, key *Key, bins ...*Bin) error
- func (clnt *Client) BatchExists(policy *BatchPolicy, keys []*Key) ([]bool, error)
- func (clnt *Client) BatchGet(policy *BatchPolicy, keys []*Key, binNames ...string) ([]*Record, error)
- func (clnt *Client) BatchGetComplex(policy *BatchPolicy, records []*BatchRead) error
- func (clnt *Client) BatchGetHeader(policy *BatchPolicy, keys []*Key) ([]*Record, error)
- func (clnt *Client) BatchGetObjects(policy *BatchPolicy, keys []*Key, objects []interface{}) (found []bool, err error)
- func (clnt *Client) ChangePassword(policy *AdminPolicy, user string, password string) error
- func (clnt *Client) Close()
- func (clnt *Client) Cluster() *Cluster
- func (clnt *Client) CreateComplexIndex(policy *WritePolicy, namespace string, setName string, indexName string, ...) (*IndexTask, error)
- func (clnt *Client) CreateIndex(policy *WritePolicy, namespace string, setName string, indexName string, ...) (*IndexTask, error)
- func (clnt *Client) CreateRole(policy *AdminPolicy, roleName string, privileges []Privilege, ...) error
- func (clnt *Client) CreateUser(policy *AdminPolicy, user string, password string, roles []string) 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) DropRole(policy *AdminPolicy, roleName string) error
- func (clnt *Client) DropUser(policy *AdminPolicy, user 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) ExecuteUDFNode(policy *QueryPolicy, node *Node, 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) GetNodeNames() []string
- func (clnt *Client) GetNodes() []*Node
- func (clnt *Client) GetObject(policy *BasePolicy, key *Key, obj interface{}) error
- func (clnt *Client) GrantPrivileges(policy *AdminPolicy, roleName string, privileges []Privilege) error
- func (clnt *Client) GrantRoles(policy *AdminPolicy, user string, roles []string) error
- 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, binMap BinMap) error
- func (clnt *Client) PrependBins(policy *WritePolicy, key *Key, bins ...*Bin) error
- func (clnt *Client) Put(policy *WritePolicy, key *Key, binMap BinMap) error
- func (clnt *Client) PutBins(policy *WritePolicy, key *Key, bins ...*Bin) error
- func (clnt *Client) PutObject(policy *WritePolicy, key *Key, obj interface{}) (err error)
- func (clnt *Client) Query(policy *QueryPolicy, statement *Statement) (*Recordset, error)
- func (clnt *Client) QueryAggregate(policy *QueryPolicy, statement *Statement, packageName, functionName string, ...) (*Recordset, error)
- func (clnt *Client) QueryExecute(policy *QueryPolicy, writePolicy *WritePolicy, statement *Statement, ...) (*ExecuteTask, error)
- func (clnt *Client) QueryNode(policy *QueryPolicy, node *Node, statement *Statement) (*Recordset, error)
- 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) QueryRole(policy *AdminPolicy, role string) (*Role, error)
- func (clnt *Client) QueryRoles(policy *AdminPolicy) ([]*Role, error)
- func (clnt *Client) QueryUser(policy *AdminPolicy, user string) (*UserRoles, error)
- func (clnt *Client) QueryUsers(policy *AdminPolicy) ([]*UserRoles, 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) RevokePrivileges(policy *AdminPolicy, roleName string, privileges []Privilege) error
- func (clnt *Client) RevokeRoles(policy *AdminPolicy, user string, roles []string) error
- func (clnt *Client) ScanAll(apolicy *ScanPolicy, namespace string, setName string, binNames ...string) (*Recordset, error)
- func (clnt *Client) ScanAllObjects(apolicy *ScanPolicy, objChan interface{}, namespace string, setName string, ...) (*Recordset, error)
- func (clnt *Client) ScanNode(apolicy *ScanPolicy, node *Node, namespace string, setName string, ...) (*Recordset, error)
- func (clnt *Client) ScanNodeObjects(apolicy *ScanPolicy, node *Node, objChan interface{}, namespace string, ...) (*Recordset, error)
- func (clnt *Client) SetWhitelist(policy *AdminPolicy, roleName string, whitelist []string) error
- func (clnt *Client) Stats() (map[string]interface{}, error)
- func (clnt *Client) String() string
- func (clnt *Client) Touch(policy *WritePolicy, key *Key) error
- func (clnt *Client) Truncate(policy *WritePolicy, namespace, set string, beforeLastUpdate *time.Time) error
- func (clnt *Client) WarmUp(count int) (int, error)
- type ClientPolicy
- type Cluster
- func (clstr *Cluster) AddSeeds(hosts []*Host)
- func (clstr *Cluster) ClientPolicy() (res ClientPolicy)
- func (clstr *Cluster) Close()
- func (clstr *Cluster) GetAliases() map[Host]*Node
- func (clstr *Cluster) GetNodeByName(nodeName string) (*Node, error)
- func (clstr *Cluster) GetNodes() []*Node
- func (clstr *Cluster) GetRandomNode() (*Node, error)
- func (clstr *Cluster) GetSeeds() []Host
- func (clstr *Cluster) IsConnected() bool
- func (clstr *Cluster) MigrationInProgress(timeout time.Duration) (res bool, err error)
- func (clstr *Cluster) Password() (res []byte)
- func (clstr *Cluster) String() string
- func (clstr *Cluster) WaitUntillMigrationIsFinished(timeout time.Duration) (err error)
- func (clstr *Cluster) WarmUp(count int) (int, error)
- type CommitLevel
- type Connection
- func (ctn *Connection) Authenticate(user string, password string) error
- func (ctn *Connection) Close()
- func (ctn *Connection) IsConnected() bool
- func (ctn *Connection) Login(policy *ClientPolicy) error
- func (ctn *Connection) Read(buf []byte, length int) (total int, err error)
- func (ctn *Connection) SetTimeout(deadline time.Time, socketTimeout time.Duration) error
- func (ctn *Connection) Write(buf []byte) (total int, err error)
- type DropIndexTask
- type ExecuteTask
- type FieldType
- type Filter
- func NewContainsFilter(binName string, indexCollectionType IndexCollectionType, value interface{}) *Filter
- func NewContainsRangeFilter(binName string, indexCollectionType IndexCollectionType, begin, end int64) *Filter
- func NewEqualFilter(binName string, value interface{}) *Filter
- func NewGeoRegionsContainingPointFilter(binName, point string) *Filter
- func NewGeoRegionsContainingPointForCollectionFilter(binName string, collectionType IndexCollectionType, point string) *Filter
- func NewGeoWithinRadiusFilter(binName string, lng, lat, radius float64) *Filter
- func NewGeoWithinRadiusForCollectionFilter(binName string, collectionType IndexCollectionType, lng, lat, radius float64) *Filter
- func NewGeoWithinRegionFilter(binName, region string) *Filter
- func NewGeoWithinRegionForCollectionFilter(binName string, collectionType IndexCollectionType, region string) *Filter
- func NewRangeFilter(binName string, begin int64, end int64) *Filter
- type FloatValue
- type GenerationPolicy
- type GeoJSONValue
- type HLLPolicy
- type HLLValue
- type Host
- type IndexCollectionType
- type IndexTask
- type IndexType
- type InfinityValue
- type InfoPolicy
- type IntegerValue
- type JsonValue
- type Key
- type Language
- type ListIter
- type ListOrderType
- type ListPolicy
- type ListReturnType
- type ListValue
- type ListerValue
- type LongValue
- type MapIter
- type MapPair
- type MapPolicy
- type MapValue
- type MapperValue
- type MultiPolicy
- type Node
- func (nd *Node) Close()
- 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) InvalidateConnection(conn *Connection)
- func (nd *Node) IsActive() bool
- func (nd *Node) MigrationInProgress() (bool, error)
- func (nd *Node) PutConnection(conn *Connection)
- func (nd *Node) Rack(namespace string) (int, error)
- func (nd *Node) Refresh(peers *peers) error
- func (nd *Node) RequestInfo(policy *InfoPolicy, name ...string) (map[string]string, error)
- func (node *Node) RequestStats(policy *InfoPolicy) (map[string]string, error)
- func (nd *Node) String() string
- func (nd *Node) WaitUntillMigrationIsFinished(timeout time.Duration) (err error)
- func (nd *Node) WarmUp(count int) (int, error)
- type NodeError
- type NullValue
- type Operation
- func AddOp(bin *Bin) *Operation
- func AppendOp(bin *Bin) *Operation
- func BitAddOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value int64, ...) *Operation
- func BitAndOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ...) *Operation
- func BitCountOp(binName string, bitOffset int, bitSize int, ctx ...*CDTContext) *Operation
- func BitGetIntOp(binName string, bitOffset int, bitSize int, signed bool, ctx ...*CDTContext) *Operation
- func BitGetOp(binName string, bitOffset int, bitSize int, ctx ...*CDTContext) *Operation
- func BitInsertOp(policy *BitPolicy, binName string, byteOffset int, value []byte, ...) *Operation
- func BitLScanOp(binName string, bitOffset int, bitSize int, value bool, ctx ...*CDTContext) *Operation
- func BitLShiftOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, shift int, ...) *Operation
- func BitNotOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, ...) *Operation
- func BitOrOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ...) *Operation
- func BitRScanOp(binName string, bitOffset int, bitSize int, value bool, ctx ...*CDTContext) *Operation
- func BitRShiftOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, shift int, ...) *Operation
- func BitRemoveOp(policy *BitPolicy, binName string, byteOffset int, byteSize int, ...) *Operation
- func BitResizeOp(policy *BitPolicy, binName string, byteSize int, resizeFlags int, ...) *Operation
- func BitSetIntOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value int64, ...) *Operation
- func BitSetOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ...) *Operation
- func BitSubtractOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value int64, ...) *Operation
- func BitXorOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ...) *Operation
- func DeleteOp() *Operation
- func GetHeaderOp() *Operation
- func GetOp() *Operation
- func GetOpForBin(binName string) *Operation
- func HLLAddOp(policy *HLLPolicy, binName string, list []Value, ...) *Operation
- func HLLDescribeOp(binName string) *Operation
- func HLLFoldOp(binName string, indexBitCount int) *Operation
- func HLLGetCountOp(binName string) *Operation
- func HLLGetIntersectCountOp(binName string, list []HLLValue) *Operation
- func HLLGetSimilarityOp(binName string, list []HLLValue) *Operation
- func HLLGetUnionCountOp(binName string, list []HLLValue) *Operation
- func HLLGetUnionOp(binName string, list []HLLValue) *Operation
- func HLLInitOp(policy *HLLPolicy, binName string, indexBitCount, minHashBitCount int) *Operation
- func HLLRefreshCountOp(binName string) *Operation
- func HLLSetUnionOp(policy *HLLPolicy, binName string, list []HLLValue) *Operation
- func ListAppendOp(binName string, values ...interface{}) *Operation
- func ListAppendWithPolicyContextOp(policy *ListPolicy, binName string, ctx []*CDTContext, values ...interface{}) *Operation
- func ListAppendWithPolicyOp(policy *ListPolicy, binName string, values ...interface{}) *Operation
- func ListClearOp(binName string, ctx ...*CDTContext) *Operation
- func ListCreateOp(binName string, listOrder ListOrderType, pad bool, ctx ...*CDTContext) *Operation
- func ListGetByIndexOp(binName string, index int, returnType ListReturnType, ctx ...*CDTContext) *Operation
- func ListGetByIndexRangeCountOp(binName string, index, count int, returnType ListReturnType, ...) *Operation
- func ListGetByIndexRangeOp(binName string, index int, returnType ListReturnType, ctx ...*CDTContext) *Operation
- func ListGetByRankOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *Operation
- func ListGetByRankRangeCountOp(binName string, rank, count int, returnType ListReturnType, ctx ...*CDTContext) *Operation
- func ListGetByRankRangeOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *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 ListGetByValueRelativeRankRangeCountOp(binName string, value interface{}, rank, count int, returnType ListReturnType, ...) *Operation
- func ListGetByValueRelativeRankRangeOp(binName string, value interface{}, rank int, returnType ListReturnType, ...) *Operation
- func ListGetOp(binName string, index int, ctx ...*CDTContext) *Operation
- func ListGetRangeFromOp(binName string, index int, ctx ...*CDTContext) *Operation
- func ListGetRangeOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
- func ListIncrementByOneOp(binName string, index int, ctx ...*CDTContext) *Operation
- func ListIncrementByOneWithPolicyOp(policy *ListPolicy, binName string, index int, ctx ...*CDTContext) *Operation
- func ListIncrementOp(binName string, index int, value interface{}, ctx ...*CDTContext) *Operation
- func ListIncrementWithPolicyOp(policy *ListPolicy, binName string, index int, value interface{}, ...) *Operation
- func ListInsertOp(binName string, index int, values ...interface{}) *Operation
- func ListInsertWithPolicyContextOp(policy *ListPolicy, binName string, index int, ctx []*CDTContext, ...) *Operation
- func ListInsertWithPolicyOp(policy *ListPolicy, binName string, index int, values ...interface{}) *Operation
- func ListPopOp(binName string, index int, ctx ...*CDTContext) *Operation
- func ListPopRangeFromOp(binName string, index int, ctx ...*CDTContext) *Operation
- func ListPopRangeOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
- func ListRemoveByIndexOp(binName string, index int, returnType ListReturnType, ctx ...*CDTContext) *Operation
- func ListRemoveByIndexRangeCountOp(binName string, index, count int, returnType ListReturnType, ...) *Operation
- func ListRemoveByIndexRangeOp(binName string, index, returnType ListReturnType, ctx ...*CDTContext) *Operation
- func ListRemoveByRankOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *Operation
- func ListRemoveByRankRangeCountOp(binName string, rank int, count int, returnType ListReturnType, ...) *Operation
- func ListRemoveByRankRangeOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *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 ListRemoveByValueRelativeRankRangeCountOp(binName string, returnType ListReturnType, value interface{}, rank, count int, ...) *Operation
- func ListRemoveByValueRelativeRankRangeOp(binName string, returnType ListReturnType, value interface{}, rank int, ...) *Operation
- func ListRemoveOp(binName string, index int, ctx ...*CDTContext) *Operation
- func ListRemoveRangeFromOp(binName string, index int, ctx ...*CDTContext) *Operation
- func ListRemoveRangeOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
- func ListSetOp(binName string, index int, value interface{}, ctx ...*CDTContext) *Operation
- func ListSetOrderOp(binName string, listOrder ListOrderType, ctx ...*CDTContext) *Operation
- func ListSizeOp(binName string, ctx ...*CDTContext) *Operation
- func ListSortOp(binName string, sortFlags int, ctx ...*CDTContext) *Operation
- func ListTrimOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
- func MapClearOp(binName string, ctx ...*CDTContext) *Operation
- func MapCreateOp(binName string, order mapOrderType, ctx []*CDTContext) *Operation
- func MapDecrementOp(policy *MapPolicy, binName string, key interface{}, decr interface{}, ...) *Operation
- func MapGetByIndexOp(binName string, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapGetByIndexRangeCountOp(binName string, index int, count int, returnType mapReturnType, ...) *Operation
- func MapGetByIndexRangeOp(binName string, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapGetByKeyListOp(binName string, keys []interface{}, returnType mapReturnType, ...) *Operation
- func MapGetByKeyOp(binName string, key interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapGetByKeyRangeOp(binName string, keyBegin interface{}, keyEnd interface{}, ...) *Operation
- func MapGetByKeyRelativeIndexRangeCountOp(binName string, key interface{}, index, count int, returnType mapReturnType, ...) *Operation
- func MapGetByKeyRelativeIndexRangeOp(binName string, key interface{}, index int, returnType mapReturnType, ...) *Operation
- func MapGetByRankOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapGetByRankRangeCountOp(binName string, rank int, count int, returnType mapReturnType, ...) *Operation
- func MapGetByRankRangeOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapGetByValueListOp(binName string, values []interface{}, returnType mapReturnType, ...) *Operation
- func MapGetByValueOp(binName string, value interface{}, returnType mapReturnType, ...) *Operation
- func MapGetByValueRangeOp(binName string, valueBegin interface{}, valueEnd interface{}, ...) *Operation
- func MapGetByValueRelativeRankRangeCountOp(binName string, value interface{}, rank, count int, returnType mapReturnType, ...) *Operation
- func MapGetByValueRelativeRankRangeOp(binName string, value interface{}, rank int, returnType mapReturnType, ...) *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, ctx ...*CDTContext) *Operation
- func MapRemoveByIndexRangeCountOp(binName string, index int, count int, returnType mapReturnType, ...) *Operation
- func MapRemoveByIndexRangeOp(binName string, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapRemoveByKeyListOp(binName string, keys []interface{}, returnType mapReturnType, ...) *Operation
- func MapRemoveByKeyOp(binName string, key interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapRemoveByKeyRangeOp(binName string, keyBegin interface{}, keyEnd interface{}, ...) *Operation
- func MapRemoveByKeyRelativeIndexRangeCountOp(binName string, key interface{}, index, count int, returnType mapReturnType, ...) *Operation
- func MapRemoveByKeyRelativeIndexRangeOp(binName string, key interface{}, index int, returnType mapReturnType, ...) *Operation
- func MapRemoveByRankOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
- func MapRemoveByRankRangeCountOp(binName string, rank int, count int, returnType mapReturnType, ...) *Operation
- func MapRemoveByRankRangeOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *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 MapRemoveByValueRelativeRankRangeCountOp(binName string, value interface{}, rank, count int, returnType mapReturnType, ...) *Operation
- func MapRemoveByValueRelativeRankRangeOp(binName string, value interface{}, rank int, returnType mapReturnType, ...) *Operation
- func MapSetPolicyOp(policy *MapPolicy, binName string, ctx ...*CDTContext) *Operation
- func MapSizeOp(binName string, ctx ...*CDTContext) *Operation
- func PrependOp(bin *Bin) *Operation
- func PutOp(bin *Bin) *Operation
- func TouchOp() *Operation
- type OperationType
- type Partition
- func (ptn *Partition) Equals(other *Partition) bool
- func (ptn *Partition) GetNodeRead(cluster *Cluster) (*Node, error)
- func (ptn *Partition) GetNodeWrite(cluster *Cluster) (*Node, error)
- func (ptn *Partition) PrepareRetryRead(isClientTimeout bool)
- func (ptn *Partition) PrepareRetryWrite(isClientTimeout bool)
- func (ptn *Partition) String() string
- type Partitions
- type Policy
- type PredExp
- type Priority
- type Privilege
- type QueryPolicy
- type ReadModeAP
- type ReadModeSC
- type Record
- type RecordExistsAction
- type Recordset
- type RegisterTask
- type RemoveTask
- type ReplicaPolicy
- type Result
- type Role
- type ScanPolicy
- type Statement
- type StringValue
- type Task
- type UDF
- type UserRoles
- type Value
- type ValueArray
- type WildCardValue
- type WritePolicy
Examples ¶
Constants ¶
const ( // BitResizeFlagsDefault specifies the defalt flag. BitResizeFlagsDefault = 0 // BitResizeFlagsFromFront Adds/removes bytes from the beginning instead of the end. BitResizeFlagsFromFront = 1 // BitResizeFlagsGrowOnly will only allow the byte[] size to increase. BitResizeFlagsGrowOnly = 2 // BitResizeFlagsShrinkOnly will only allow the byte[] size to decrease. BitResizeFlagsShrinkOnly = 4 )
const ( // BitWriteFlagsDefault allows create or update. BitWriteFlagsDefault = 0 // BitWriteFlagsCreateOnly specifies that: // If the bin already exists, the operation will be denied. // If the bin does not exist, a new bin will be created. BitWriteFlagsCreateOnly = 1 // BitWriteFlagsUpdateOnly specifies that: // If the bin already exists, the bin will be overwritten. // If the bin does not exist, the operation will be denied. BitWriteFlagsUpdateOnly = 2 // BitWriteFlagsNoFail specifies not to raise error if operation is denied. BitWriteFlagsNoFail = 4 // BitWriteFlagsPartial allows other valid operations to be committed if this operations is // denied due to flag constraints. BitWriteFlagsPartial = 8 )
const ( // ListSortFlagsDefault is the default sort flag for CDT lists, and sort in Ascending order. ListSortFlagsDefault = 0 // ListSortFlagsDescending will sort the contents of the list in descending order. ListSortFlagsDescending = 1 // ListSortFlagsDropDuplicates will drop duplicate values in the results of the CDT list operation. ListSortFlagsDropDuplicates = 2 )
const ( // ListWriteFlagsDefault is the default behavior. It means: Allow duplicate values and insertions at any index. ListWriteFlagsDefault = 0 // ListWriteFlagsAddUnique means: Only add unique values. ListWriteFlagsAddUnique = 1 // ListWriteFlagsInsertBounded means: Enforce list boundaries when inserting. Do not allow values to be inserted // at index outside current list boundaries. ListWriteFlagsInsertBounded = 2 // ListWriteFlagsNoFail means: do not raise error if a list item fails due to write flag constraints. ListWriteFlagsNoFail = 4 // ListWriteFlagsPartial means: allow other valid list items to be committed if a list item fails due to // write flag constraints. ListWriteFlagsPartial = 8 )
const ( // MapWriteFlagsDefault is the Default. Allow create or update. MapWriteFlagsDefault = 0 // MapWriteFlagsCreateOnly means: If the key already exists, the item will be denied. // If the key does not exist, a new item will be created. MapWriteFlagsCreateOnly = 1 // MapWriteFlagsUpdateOnly means: If the key already exists, the item will be overwritten. // If the key does not exist, the item will be denied. MapWriteFlagsUpdateOnly = 2 // MapWriteFlagsNoFail means: Do not raise error if a map item is denied due to write flag constraints. MapWriteFlagsNoFail = 4 // MapWriteFlagsNoFail means: Allow other valid map items to be committed if a map item is denied due to // write flag constraints. MapWriteFlagsPartial = 8 )
*
- Map write bit flags.
- Requires server versions >= 4.3.
const ( // HLLWriteFlagsDefault is Default. Allow create or update. HLLWriteFlagsDefault = 0 // HLLWriteFlagsCreateOnly behaves like the following: // If the bin already exists, the operation will be denied. // If the bin does not exist, a new bin will be created. HLLWriteFlagsCreateOnly = 1 // HLLWriteFlagsUpdateOnly behaves like the following: // If the bin already exists, the bin will be overwritten. // If the bin does not exist, the operation will be denied. HLLWriteFlagsUpdateOnly = 2 // HLLWriteFlagsNoFail does not raise error if operation is denied. HLLWriteFlagsNoFail = 4 // HLLWriteFlagsAllowFold allows the resulting set to be the minimum of provided index bits. // Also, allow the usage of less precise HLL algorithms when minHash bits // of all participating sets do not match. HLLWriteFlagsAllowFold = 8 )
const ( // UserAdmin allows to manages users and their roles. UserAdmin privilegeCode = "user-admin" // SysAdmin allows to manage indexes, user defined functions and server configuration. SysAdmin privilegeCode = "sys-admin" // DataAdmin allows to manage indicies and user defined functions. DataAdmin privilegeCode = "data-admin" // ReadWriteUDF allows read, write and UDF transactions with the database. ReadWriteUDF privilegeCode = "read-write-udf" // ReadWrite allows read and write transactions with the database. ReadWrite privilegeCode = "read-write" // Read allows read transactions with the database. Read privilegeCode = "read" // Write allows write transactions with the database. Write privilegeCode = "write" )
Pre-defined user roles.
const ( // TTLServerDefault will default to namespace configuration variable "default-ttl" on the server. TTLServerDefault = 0 // TTLDontExpire will never expire for Aerospike 2 server versions >= 2.7.2 and Aerospike 3+ server. TTLDontExpire = math.MaxUint32 // TTLDontUpdate will not change the record's ttl when record is written. Supported by Aerospike server versions >= 3.10.1 TTLDontUpdate = math.MaxUint32 - 1 )
Variables ¶
var DefaultBufferSize = 64 * 1024 // 64 KiB
DefaultBufferSize specifies the initial size of the connection buffer when it is created. If not big enough (as big as the average record), it will be reallocated to size again which will be more expensive.
var MapOrder = struct { // Map is not ordered. This is the default. UNORDERED mapOrderType // 0 // Order map by key. KEY_ORDERED mapOrderType // 1 // Order map by key, then value. KEY_VALUE_ORDERED mapOrderType // 3 }{mapOrderType{0, 0x40}, mapOrderType{1, 0x80}, mapOrderType{3, 0xc0}}
Map storage order.
var MapReturnType = struct { // Do not return a result. NONE mapReturnType // Return key index order. // // 0 = first key // N = Nth key // -1 = last key INDEX mapReturnType // Return reverse key order. // // 0 = last key // -1 = first key REVERSE_INDEX mapReturnType // Return value order. // // 0 = smallest value // N = Nth smallest value // -1 = largest value RANK mapReturnType // Return reserve value order. // // 0 = largest value // N = Nth largest value // -1 = smallest value REVERSE_RANK mapReturnType // Return count of items selected. COUNT mapReturnType // Return key for single key read and key list for range read. KEY mapReturnType // Return value for single key read and value list for range read. VALUE mapReturnType // Return key/value items. The possible return types are: // // map[interface{}]interface{} : Returned for unordered maps // []MapPair : Returned for range results where range order needs to be preserved. KEY_VALUE mapReturnType // Invert meaning of map command and return values. For example: // MapRemoveByKeyRange(binName, keyBegin, keyEnd, MapReturnType.KEY | MapReturnType.INVERTED) // With the INVERTED flag enabled, the keys outside of the specified key range will be removed and returned. INVERTED mapReturnType }{ 0, 1, 2, 3, 4, 5, 6, 7, 8, 0x10000, }
Map return type. Type of data to return when selecting or removing items from the map.
var MapWriteMode = struct { // If the key already exists, the item will be overwritten. // If the key does not exist, a new item will be created. UPDATE *mapWriteMode // If the key already exists, the item will be overwritten. // If the key does not exist, the write will fail. UPDATE_ONLY *mapWriteMode // If the key already exists, the write will fail. // If the key does not exist, a new item will be created. CREATE_ONLY *mapWriteMode }{ &mapWriteMode{_CDT_MAP_PUT, _CDT_MAP_PUT_ITEMS}, &mapWriteMode{_CDT_MAP_REPLACE, _CDT_MAP_REPLACE_ITEMS}, &mapWriteMode{_CDT_MAP_ADD, _CDT_MAP_ADD_ITEMS}, }
MapWriteMode should only be used for server versions < 4.3. MapWriteFlags are recommended for server versions >= 4.3.
var ( // MaxBufferSize protects against allocating massive memory blocks // for buffers. Tweak this number if you are returning a lot of // LDT elements in your queries. MaxBufferSize = 1024 * 1024 * 120 // 120 MB )
Functions ¶
func NewPredExpAnd ¶ added in v1.26.0
func NewPredExpAnd(nexpr uint16) *predExpAnd
NewPredExpAnd creates an AND predicate. Argument describes the number of expressions.
func NewPredExpGeoJSONBin ¶ added in v1.26.0
func NewPredExpGeoJSONBin(name string) *predExpBin
NewPredExpUnknownBin creates a Bin predicate expression which its type is GeoJSON.
func NewPredExpGeoJSONContains ¶ added in v1.26.0
func NewPredExpGeoJSONContains() *predExpCompare
NewPredExpGeoJSONContains creates Region Contains predicate for GeoJSON values
func NewPredExpGeoJSONValue ¶ added in v1.26.0
func NewPredExpGeoJSONValue(val string) *predExpGeoJSONValue
NewPredExpGeoJSONValue embeds a GeoJSON value in a predicate expression.
func NewPredExpGeoJSONVar ¶ added in v1.26.0
func NewPredExpGeoJSONVar(name string) *predExpVar
NewPredExpGeoJSONVar creates GeoJSON variable used in list/map iterations.
func NewPredExpGeoJSONWithin ¶ added in v1.26.0
func NewPredExpGeoJSONWithin() *predExpCompare
NewPredExpGeoJSONWithin creates Within Region predicate for GeoJSON values
func NewPredExpIntegerBin ¶ added in v1.26.0
func NewPredExpIntegerBin(name string) *predExpBin
NewPredExpUnknownBin creates a Bin predicate expression which its type is integer.
func NewPredExpIntegerEqual ¶ added in v1.26.0
func NewPredExpIntegerEqual() *predExpCompare
NewPredExpIntegerEqual creates Equal predicate for integer values
func NewPredExpIntegerGreater ¶ added in v1.26.0
func NewPredExpIntegerGreater() *predExpCompare
NewPredExpIntegerGreater creates Greater Than predicate for integer values
func NewPredExpIntegerGreaterEq ¶ added in v1.26.0
func NewPredExpIntegerGreaterEq() *predExpCompare
NewPredExpIntegerGreaterEq creates Greater Than Or Equal predicate for integer values
func NewPredExpIntegerLess ¶ added in v1.26.0
func NewPredExpIntegerLess() *predExpCompare
NewPredExpIntegerLess creates Less Than predicate for integer values
func NewPredExpIntegerLessEq ¶ added in v1.26.0
func NewPredExpIntegerLessEq() *predExpCompare
NewPredExpIntegerLessEq creates Less Than Or Equal predicate for integer values
func NewPredExpIntegerUnequal ¶ added in v1.26.0
func NewPredExpIntegerUnequal() *predExpCompare
NewPredExpIntegerUnequal creates NotEqual predicate for integer values
func NewPredExpIntegerValue ¶ added in v1.26.0
func NewPredExpIntegerValue(val int64) *predExpIntegerValue
NewPredExpIntegerValue embeds an int64 value in a predicate expression.
func NewPredExpIntegerVar ¶ added in v1.26.0
func NewPredExpIntegerVar(name string) *predExpVar
NewPredExpIntegerVar creates 64 bit integer variable used in list/map iterations.
func NewPredExpListBin ¶ added in v1.26.0
func NewPredExpListBin(name string) *predExpBin
NewPredExpUnknownBin creates a Bin predicate expression which its type is List.
func NewPredExpListIterateAnd ¶ added in v1.26.0
func NewPredExpListIterateAnd(name string) *predExpIter
NewPredExpListIterateAnd creates an And iterator predicate for list items
func NewPredExpListIterateOr ¶ added in v1.26.0
func NewPredExpListIterateOr(name string) *predExpIter
NewPredExpListIterateOr creates an Or iterator predicate for list items
func NewPredExpMapBin ¶ added in v1.26.0
func NewPredExpMapBin(name string) *predExpBin
NewPredExpUnknownBin creates a Bin predicate expression which its type is Map.
func NewPredExpMapKeyIterateAnd ¶ added in v1.26.0
func NewPredExpMapKeyIterateAnd(name string) *predExpIter
NewPredExpMapKeyIterateAnd creates an And iterator predicate on map keys
func NewPredExpMapKeyIterateOr ¶ added in v1.26.0
func NewPredExpMapKeyIterateOr(name string) *predExpIter
NewPredExpMapKeyIterateOr creates an Or iterator predicate on map keys
func NewPredExpMapValIterateAnd ¶ added in v1.26.0
func NewPredExpMapValIterateAnd(name string) *predExpIter
NewPredExpMapKeyIterateAnd creates an And iterator predicate on map values
func NewPredExpMapValIterateOr ¶ added in v1.26.0
func NewPredExpMapValIterateOr(name string) *predExpIter
NewPredExpMapValIterateOr creates an Or iterator predicate on map values
func NewPredExpNot ¶ added in v1.26.0
func NewPredExpNot() *predExpNot
NewPredExpNot creates a NOT predicate
func NewPredExpOr ¶ added in v1.26.0
func NewPredExpOr(nexpr uint16) *predExpOr
NewPredExpOr creates an OR predicate. Argument describes the number of expressions.
func NewPredExpRecDeviceSize ¶ added in v1.26.0
func NewPredExpRecDeviceSize() *predExpMD
NewPredExpRecDeviceSize creates record size on disk predicate
func NewPredExpRecDigestModulo ¶ added in v1.26.0
func NewPredExpRecDigestModulo(mod int32) *predExpMDDigestModulo
NewPredExpRecDigestModulo creates a digest modulo record metadata value predicate expression. The digest modulo expression assumes the value of 4 bytes of the record's key digest modulo as its argument. This predicate is available in Aerospike server versions 3.12.1+
For example, the following sequence of predicate expressions selects records that have digest(key) % 3 == 1): stmt.SetPredExp(
NewPredExpRecDigestModulo(3), NewPredExpIntegerValue(1), NewPredExpIntegerEqual(),
)
func NewPredExpRecLastUpdate ¶ added in v1.26.0
func NewPredExpRecLastUpdate() *predExpMD
NewPredExpRecLastUpdate creates record last update predicate
func NewPredExpRecVoidTime ¶ added in v1.26.0
func NewPredExpRecVoidTime() *predExpMD
NewPredExpRecVoidTime creates record expiration time predicate expressed in nanoseconds since 1970-01-01 epoch as 64 bit integer.
func NewPredExpStringBin ¶ added in v1.26.0
func NewPredExpStringBin(name string) *predExpBin
NewPredExpUnknownBin creates a Bin predicate expression which its type is String.
func NewPredExpStringEqual ¶ added in v1.26.0
func NewPredExpStringEqual() *predExpCompare
NewPredExpStringEqual creates Equal predicate for string values
func NewPredExpStringRegex ¶ added in v1.26.0
func NewPredExpStringRegex(cflags uint32) *predExpStringRegex
NewPredExpStringRegex creates a Regex predicate
func NewPredExpStringUnequal ¶ added in v1.26.0
func NewPredExpStringUnequal() *predExpCompare
NewPredExpStringUnequal creates Not Equal predicate for string values
func NewPredExpStringValue ¶ added in v1.26.0
func NewPredExpStringValue(val string) *predExpStringValue
NewPredExpStringValue embeds a string value in a predicate expression.
func NewPredExpStringVar ¶ added in v1.26.0
func NewPredExpStringVar(name string) *predExpVar
NewPredExpStringVar creates string variable used in list/map iterations.
func NewPredExpUnknownBin ¶ added in v1.26.0
func NewPredExpUnknownBin(name string) *predExpBin
NewPredExpUnknownBin creates a Bin predicate expression which its type is not known.
func PackFloat32 ¶ added in v1.23.0
PackFloat32 packs float32 value
func PackFloat64 ¶ added in v1.23.0
PackFloat64 packs float64 value
func PackString ¶ added in v1.23.0
PackString packs a string
func PackUInt64 ¶ added in v1.23.0
PackUInt64 packs a uint64
func RequestInfo ¶
func RequestInfo(conn *Connection, names ...string) (map[string]string, error)
RequestInfo gets info values by name from the specified connection. Timeout should already be set on the connection.
func SetAerospikeTag ¶ added in v1.20.0
func SetAerospikeTag(tag string)
SetAerospikeTag sets the bin tag to the specified tag. This will be useful for when a user wants to use the same tag name for two different concerns. For example, one will be able to use the same tag name for both json and aerospike bin name.
func SetLuaPath ¶ added in v1.10.0
func SetLuaPath(lpath string)
SetLuaPath sets the Lua interpreter path to files This path is used to load UDFs for QueryAggregate command
Types ¶
type AdminPolicy ¶ added in v1.3.0
type AdminPolicy struct { // User administration command socket timeout. // Default is 2 seconds. Timeout time.Duration }
AdminPolicy contains attributes used for user administration commands.
func NewAdminPolicy ¶ added in v1.3.0
func NewAdminPolicy() *AdminPolicy
NewAdminPolicy generates a new AdminPolicy with default values.
type AerospikeBlob ¶
type AuthMode ¶ added in v1.35.0
type AuthMode int
AuthMode determines authentication mode when user/password is defined.
const ( // AuthModeInternal uses internal authentication only. Hashed password is stored on the server. // Do not send clear password. This is the default. AuthModeInternal AuthMode = iota // AuthModeExternal uses external authentication (like LDAP). Specific external authentication is // configured on server. If TLSConfig is defined, sends clear password on node login via TLS. // Will return an error if TLSConfig is not defined. AuthModeExternal )
type BasePolicy ¶
type BasePolicy struct { Policy // PredExps is the optional predicate expression filter in postfix notation. If the predicate // expression exists and evaluates to false, the transaction is ignored. // // Default: nil PredExp []PredExp // Priority of request relative to other transactions. // Currently, only used for scans. Priority Priority //= Priority.DEFAULT; // ReadModeAP indicates read policy for AP (availability) namespaces. ReadModeAP ReadModeAP //= ONE // ReadModeSC indicates read policy for SC (strong consistency) namespaces. ReadModeSC ReadModeSC //= SESSION; // TotalTimeout specifies total transaction timeout. // // The TotalTimeout is tracked on the client and also sent to the server along // with the transaction in the wire protocol. The client will most likely // timeout first, but the server has the capability to Timeout the transaction. // // If TotalTimeout is not zero and TotalTimeout is reached before the transaction // completes, the transaction will abort with TotalTimeout error. // // If TotalTimeout is zero, there will be no time limit and the transaction will retry // on network timeouts/errors until MaxRetries is exceeded. If MaxRetries is exceeded, the // transaction also aborts with Timeout error. // // Default: 0 (no time limit and rely on MaxRetries). TotalTimeout time.Duration // SocketTimeout determines network timeout for each attempt. // // If SocketTimeout is not zero and SocketTimeout is reached before an attempt completes, // the Timeout above is checked. If Timeout is not exceeded, the transaction // is retried. If both SocketTimeout and Timeout are non-zero, SocketTimeout must be less // than or equal to Timeout, otherwise Timeout will also be used for SocketTimeout. // // Default: 30s SocketTimeout time.Duration // MaxRetries determines the maximum number of retries before aborting the current transaction. // The initial attempt is not counted as a retry. // // If MaxRetries is exceeded, the transaction will abort with an error. // // WARNING: Database writes that are not idempotent (such as AddOp) // should not be retried because the write operation may be performed // multiple times if the client timed out previous transaction attempts. // It's important to use a distinct WritePolicy for non-idempotent // writes which sets maxRetries = 0; // // Default for read: 2 (initial attempt + 2 retries = 3 attempts) // // Default for write/query/scan: 0 (no retries) MaxRetries int //= 2; // SleepBetweenRtries determines the duration to sleep between retries. Enter zero to skip sleep. // This field is ignored when maxRetries is zero. // This field is also ignored in async mode. // // The sleep only occurs on connection errors and server timeouts // which suggest a node is down and the cluster is reforming. // The sleep does not occur when the client's socketTimeout expires. // // Reads do not have to sleep when a node goes down because the cluster // does not shut out reads during cluster reformation. The default for // reads is zero. // // The default for writes is also zero because writes are not retried by default. // Writes need to wait for the cluster to reform when a node goes down. // Immediate write retries on node failure have been shown to consistently // result in errors. If maxRetries is greater than zero on a write, then // sleepBetweenRetries should be set high enough to allow the cluster to // reform (>= 500ms). SleepBetweenRetries time.Duration //= 1ms; // SleepMultiplier specifies the multiplying factor to be used for exponential backoff during retries. // Default to (1.0); Only values greater than 1 are valid. SleepMultiplier float64 //= 1.0; // SendKey determines to whether send user defined key in addition to hash digest on both reads and writes. // If the key is sent on a write, the key will be stored with the record on // the server. // The default is to not send the user defined key. SendKey bool // = false // UseCompression tells the server to compress its response using zlib. // Use zlib compression on write or batch read commands when the command buffer size is greater // than 128 bytes. In addition, it directs the server to compress its response on read commands. // The server response compression threshold is also 128 bytes. // // This option will increase CPU and memory usage (for extra compressed buffers), but // decrease the size of data sent over the network. // // Default: false UseCompression bool // = false // ReplicaPolicy determines the node to send the read commands containing the key's partition replica type. // Write commands are not affected by this setting, because all writes are directed // to the node containing the key's master partition. // Scan and query are also not affected by replica algorithms. // Default to sending read commands to the node containing the key's master partition. ReplicaPolicy ReplicaPolicy }
BasePolicy encapsulates parameters for transaction policy attributes used in all database operation calls.
func NewPolicy ¶
func NewPolicy() *BasePolicy
NewPolicy generates a new BasePolicy instance with default values.
func (*BasePolicy) GetBasePolicy ¶
func (p *BasePolicy) GetBasePolicy() *BasePolicy
GetBasePolicy returns embedded BasePolicy in all types that embed this struct.
type BatchError ¶
BatchError is a type to encapsulate the node that the error occurred in.
type BatchPolicy ¶ added in v1.31.0
type BatchPolicy struct { BasePolicy // Maximum number of concurrent batch request goroutines to server nodes at any point in time. // If there are 16 node/namespace combinations requested and ConcurrentNodes is 8, // then batch requests will be made for 8 node/namespace combinations in concurrent goroutines. // When a request completes, a new request will be issued until all 16 goroutines are complete. // // Values: // 1: Issue batch requests sequentially. This mode has a performance advantage for small // to medium sized batch sizes because requests can be issued in the main transaction goroutine. // This is the default. // 0: Issue all batch requests in concurrent goroutines. This mode has a performance // advantage for extremely large batch sizes because each node can process the request // immediately. The downside is extra goroutines will need to be created (or taken from // a goroutine pool). // > 0: Issue up to ConcurrentNodes batch requests in concurrent goroutines. When a request // completes, a new request will be issued until all goroutines are complete. This mode // prevents too many concurrent goroutines being created for large cluster implementations. // The downside is extra goroutines will still need to be created (or taken from a goroutine pool). ConcurrentNodes int // = 1 // Allow batch to be processed immediately in the server's receiving thread when the server // deems it to be appropriate. If false, the batch will always be processed in separate // transaction goroutines. This field is only relevant for the new batch index protocol. // // For batch exists or batch reads of smaller sized records (<= 1K per record), inline // processing will be significantly faster on "in memory" namespaces. The server disables // inline processing on disk based namespaces regardless of this policy field. // // Inline processing can introduce the possibility of unfairness because the server // can process the entire batch before moving onto the next command. AllowInline bool //= true // AllowPartialResults determines if the results for some nodes should be returned in case // some nodes encounter an error. The result for the unreceived records will be nil. // The returned records will be safe to use, since only fully received data will be parsed // and set. // // This flag is only supported for BatchGet and BatchGetHeader methods. BatchGetComplex always returns // partial results by design. AllowPartialResults bool //= false // Send set name field to server for every key in the batch for batch index protocol. // This is only necessary when authentication is enabled and security roles are defined // on a per set basis. SendSetName bool //= false }
BatchPolicy encapsulates parameters for policy attributes used in write operations. This object is passed into methods where database writes can occur.
func NewBatchPolicy ¶ added in v1.31.0
func NewBatchPolicy() *BatchPolicy
NewBatchPolicy initializes a new BatchPolicy instance with default parameters.
type BatchRead ¶ added in v1.31.0
type BatchRead struct { // Key specifies the key to retrieve. Key *Key // BinNames specifies the Bins to retrieve for this key. BinNames []string // ReadAllBins defines what data should be read from the record. // If true, ignore binNames and read all bins. // If false and binNames are set, read specified binNames. // If false and binNames are not set, read record header (generation, expiration) only. ReadAllBins bool //= false // Record result after batch command has completed. Will be null if record was not found. Record *Record }
BatchRead specifies the Key and bin names used in batch read commands where variable bins are needed for each key.
func NewBatchRead ¶ added in v1.31.0
NewBatchRead defines a key and bins to retrieve in a batch operation.
func NewBatchReadHeader ¶ added in v1.31.0
NewBatchRead defines a key to retrieve the record headers only in a batch operation.
type Bin ¶
type Bin struct { // Bin name. Current limit is 14 characters. Name string // Bin value. Value Value }
Bin encapsulates a field name/value pair.
type BinMap ¶
type BinMap map[string]interface{}
BinMap is used to define a map of bin names to values.
type BitOverflowAction ¶
type BitOverflowAction int
BitOverflowAction specifies the action to take when bitwise add/subtract results in overflow/underflow.
const ( // BitOverflowActionFail specifies to fail operation with error. BitOverflowActionFail BitOverflowAction = 0 // BitOverflowActionSaturate specifies that in add/subtract overflows/underflows, set to max/min value. // Example: MAXINT + 1 = MAXINT BitOverflowActionSaturate BitOverflowAction = 2 // BitOverflowActionFail specifies that in add/subtract overflows/underflows, wrap the value. // Example: MAXINT + 1 = -1 BitOverflowActionWrap BitOverflowAction = 4 )
type BitPolicy ¶
type BitPolicy struct {
// contains filtered or unexported fields
}
BitPolicy determines the Bit operation policy.
func DefaultBitPolicy ¶
func DefaultBitPolicy() *BitPolicy
func NewBitPolicy ¶
type BufferEx ¶ added in v1.23.0
type BufferEx interface { WriteInt64(num int64) (int, error) WriteUint64(num uint64) (int, error) WriteInt32(num int32) (int, error) WriteUint32(num uint32) (int, error) WriteInt16(num int16) (int, error) WriteUint16(num uint16) (int, error) WriteFloat32(float float32) (int, error) WriteFloat64(float float64) (int, error) WriteByte(b byte) error WriteString(s string) (int, error) Write(b []byte) (int, error) }
BufferEx is a specialized buffer interface for aerospike client.
type BytesValue ¶
type BytesValue []byte
BytesValue encapsulates an array of bytes.
func NewBlobValue ¶
func NewBlobValue(object AerospikeBlob) BytesValue
NewBlobValue accepts an AerospikeBlob interface, and automatically converts it to a BytesValue. If Encode returns an err, it will panic.
func NewBytesValue ¶
func NewBytesValue(bytes []byte) BytesValue
NewBytesValue generates a ByteValue instance.
func (BytesValue) EstimateSize ¶
func (vl BytesValue) EstimateSize() (int, error)
func (BytesValue) GetObject ¶
func (vl BytesValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (BytesValue) GetType ¶
func (vl BytesValue) GetType() int
GetType returns wire protocol value type.
func (BytesValue) String ¶
func (vl BytesValue) String() string
String implements Stringer interface.
type CDTContext ¶
type CDTContext struct {
// contains filtered or unexported fields
}
CDTContext defines Nested CDT context. Identifies the location of nested list/map to apply the operation. for the current level. An array of CTX identifies location of the list/map on multiple levels on nesting.
func CtxListIndex ¶
func CtxListIndex(index int) *CDTContext
CtxListIndex defines Lookup list by index offset. If the index is negative, the resolved index starts backwards from end of list. If an index is out of bounds, a parameter error will be returned. Examples: 0: First item. 4: Fifth item. -1: Last item. -3: Third to last item.
func CtxListIndexCreate ¶
func CtxListIndexCreate(index int, order ListOrderType, pad bool) *CDTContext
CtxListIndexCreate list with given type at index offset, given an order and pad.
func CtxListRank ¶
func CtxListRank(rank int) *CDTContext
CtxListRank defines Lookup list by rank. 0 = smallest value N = Nth smallest value -1 = largest value
func CtxListValue ¶
func CtxListValue(key Value) *CDTContext
CtxListValue defines Lookup list by value.
func CtxMapIndex ¶
func CtxMapIndex(index int) *CDTContext
CtxMapIndex defines Lookup map by index offset. If the index is negative, the resolved index starts backwards from end of list. If an index is out of bounds, a parameter error will be returned. Examples: 0: First item. 4: Fifth item. -1: Last item. -3: Third to last item.
func CtxMapKeyCreate ¶
func CtxMapKeyCreate(key Value, order mapOrderType) *CDTContext
Create map with given type at map key.
func CtxMapRank ¶
func CtxMapRank(rank int) *CDTContext
CtxMapRank defines Lookup map by rank. 0 = smallest value N = Nth smallest value -1 = largest value
type Client ¶
type Client struct { // DefaultPolicy is used for all read commands without a specific policy. DefaultPolicy *BasePolicy // DefaultBatchPolicy is used for all batch commands without a specific policy. DefaultBatchPolicy *BatchPolicy // DefaultWritePolicy is used for all write commands without a specific policy. DefaultWritePolicy *WritePolicy // DefaultScanPolicy is used for all scan commands without a specific policy. DefaultScanPolicy *ScanPolicy // DefaultQueryPolicy is used for all query commands without a specific policy. DefaultQueryPolicy *QueryPolicy // DefaultAdminPolicy is used for all security commands without a specific policy. DefaultAdminPolicy *AdminPolicy // contains filtered or unexported fields }
Client encapsulates an Aerospike cluster. All database operations are available against this object.
func NewClientWithPolicy ¶
func NewClientWithPolicy(policy *ClientPolicy, hostname string, port int) (*Client, error)
NewClientWithPolicy generates a new Client using the specified ClientPolicy. If the policy is nil, the default relevant policy will be used.
func NewClientWithPolicyAndHost ¶
func NewClientWithPolicyAndHost(policy *ClientPolicy, hosts ...*Host) (*Client, error)
NewClientWithPolicyAndHost generates a new Client the specified ClientPolicy and sets up the cluster using the provided hosts. If the policy is nil, the default relevant policy will be used.
func (*Client) Add ¶
func (clnt *Client) Add(policy *WritePolicy, key *Key, binMap BinMap) error
Add adds integer bin values to existing record bin values. The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. This call only works for integer values. If the policy is nil, the default relevant policy will be used.
Example ¶
key, err := as.NewKey("test", "test", "addkey") if err != nil { log.Fatal(err) } if _, err = client.Delete(nil, key); err != nil { log.Fatal(err) } // Add to a non-existing record/bin, should create a record bin := as.NewBin("bin", 10) if err = client.AddBins(nil, key, bin); err != nil { log.Fatal(err) } // Add to 5 to the original 10 bin = as.NewBin("bin", 5) if err = client.AddBins(nil, key, bin); err != nil { log.Fatal(err) } // Check the result record, err := client.Get(nil, key, bin.Name) if err != nil { log.Fatal(err) } fmt.Println(record.Bins["bin"]) // Demonstrate add and get combined. bin = as.NewBin("bin", 30) if record, err = client.Operate(nil, key, as.AddOp(bin), as.GetOp()); err != nil { log.Fatal(err) } fmt.Println(record.Bins["bin"])
Output: 15 45
func (*Client) AddBins ¶
func (clnt *Client) AddBins(policy *WritePolicy, key *Key, bins ...*Bin) error
AddBins works the same as Add, but avoids BinMap allocation and iteration.
func (*Client) Append ¶
func (clnt *Client) Append(policy *WritePolicy, key *Key, binMap BinMap) error
Append appends bin value's string to existing record bin values. The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. This call only works for string and []byte values. If the policy is nil, the default relevant policy will be used.
Example ¶
key, err := as.NewKey("test", "test", "appendkey") if err != nil { log.Fatal(err) } if _, err = client.Delete(nil, key); err != nil { log.Fatal(err) } // Create by appending to non-existing value bin1 := as.NewBin("myBin", "Hello") if err = client.AppendBins(nil, key, bin1); err != nil { log.Fatal(err) } // Append World bin2 := as.NewBin("myBin", " World") if err = client.AppendBins(nil, key, bin2); err != nil { log.Fatal(err) } record, err := client.Get(nil, key) if err != nil { log.Fatal(err) } fmt.Println(record.Bins["myBin"])
Output: Hello World
func (*Client) AppendBins ¶
func (clnt *Client) AppendBins(policy *WritePolicy, key *Key, bins ...*Bin) error
AppendBins works the same as Append, but avoids BinMap allocation and iteration.
func (*Client) BatchExists ¶ added in v1.0.1
func (clnt *Client) BatchExists(policy *BatchPolicy, keys []*Key) ([]bool, error)
BatchExists determines if multiple record keys exist in one batch request. The returned boolean array is in positional order with the original key array order. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) BatchGet ¶ added in v1.0.1
func (clnt *Client) BatchGet(policy *BatchPolicy, keys []*Key, binNames ...string) ([]*Record, error)
BatchGet reads multiple record headers and bins for specified keys in one batch request. The returned records are in positional order with the original key array order. If a key is not found, the positional record will be nil. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) BatchGetComplex ¶ added in v1.31.0
func (clnt *Client) BatchGetComplex(policy *BatchPolicy, records []*BatchRead) error
BatchGetComplex reads multiple records for specified batch keys in one batch call. This method allows different namespaces/bins to be requested for each key in the batch. The returned records are located in the same list. If the BatchRead key field is not found, the corresponding record field will be null. The policy can be used to specify timeouts and maximum concurrent threads. This method requires Aerospike Server version >= 3.6.0.
func (*Client) BatchGetHeader ¶ added in v1.0.1
func (clnt *Client) BatchGetHeader(policy *BatchPolicy, keys []*Key) ([]*Record, error)
BatchGetHeader reads multiple record header data for specified keys in one batch request. The returned records are in positional order with the original key array order. If a key is not found, the positional record will be nil. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) BatchGetObjects ¶ added in v1.27.0
func (clnt *Client) BatchGetObjects(policy *BatchPolicy, keys []*Key, objects []interface{}) (found []bool, err error)
BatchGetObject reads multiple record headers and bins for specified keys in one batch request. The returned objects are in positional order with the original key array order. If a key is not found, the positional object will not change, and the positional found boolean will be false. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) ChangePassword ¶ added in v1.3.0
func (clnt *Client) ChangePassword(policy *AdminPolicy, user string, password string) error
ChangePassword changes a user's password. Clear-text password will be hashed using bcrypt before sending to server.
func (*Client) Close ¶
func (clnt *Client) Close()
Close closes all client connections to database server nodes.
func (*Client) CreateComplexIndex ¶ added in v1.7.0
func (clnt *Client) CreateComplexIndex( policy *WritePolicy, namespace string, setName string, indexName string, binName string, indexType IndexType, indexCollectionType IndexCollectionType, ) (*IndexTask, error)
CreateComplexIndex creates a secondary index, with the ability to put indexes on bin containing complex data types, e.g: Maps and Lists. This asynchronous server call will return before the command is complete. The user can optionally wait for command completion by using the returned IndexTask instance. This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) CreateIndex ¶ added in v1.0.1
func (clnt *Client) CreateIndex( policy *WritePolicy, namespace string, setName string, indexName string, binName string, indexType IndexType, ) (*IndexTask, error)
CreateIndex creates a secondary index. This asynchronous server call will return before the command is complete. The user can optionally wait for command completion by using the returned IndexTask instance. This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) CreateRole ¶ added in v1.24.0
func (clnt *Client) CreateRole(policy *AdminPolicy, roleName string, privileges []Privilege, whitelist []string) error
CreateRole creates a user-defined role.
func (*Client) CreateUser ¶ added in v1.3.0
func (clnt *Client) CreateUser(policy *AdminPolicy, user string, password string, roles []string) error
CreateUser creates a new user with password and roles. Clear-text password will be hashed using bcrypt before sending to server.
func (*Client) Delete ¶
func (clnt *Client) Delete(policy *WritePolicy, key *Key) (bool, error)
Delete deletes a record for specified key. The policy specifies the transaction timeout. If the policy is nil, the default relevant policy will be used.
func (*Client) DropIndex ¶ added in v1.0.1
func (clnt *Client) DropIndex( policy *WritePolicy, namespace string, setName string, indexName string, ) error
DropIndex deletes a secondary index. It will block until index is dropped on all nodes. This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) DropRole ¶ added in v1.24.0
func (clnt *Client) DropRole(policy *AdminPolicy, roleName string) error
DropRole removes a user-defined role.
func (*Client) DropUser ¶ added in v1.3.0
func (clnt *Client) DropUser(policy *AdminPolicy, user string) error
DropUser removes a user from the cluster.
func (*Client) Execute ¶ added in v1.0.1
func (clnt *Client) Execute(policy *WritePolicy, key *Key, packageName string, functionName string, args ...Value) (interface{}, error)
Execute executes a user defined function on server and return results. The function operates on a single record. The package name is used to locate the udf file location:
udf file = <server udf dir>/<package name>.lua
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) ExecuteUDF ¶ added in v1.0.1
func (clnt *Client) ExecuteUDF(policy *QueryPolicy, statement *Statement, packageName string, functionName string, functionArgs ...Value, ) (*ExecuteTask, error)
ExecuteUDF applies user defined function on records that match the statement filter. Records are not returned to the client. This asynchronous server call will return before command is complete. The user can optionally wait for command completion by using the returned ExecuteTask instance.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) ExecuteUDFNode ¶ added in v1.30.0
func (clnt *Client) ExecuteUDFNode(policy *QueryPolicy, node *Node, statement *Statement, packageName string, functionName string, functionArgs ...Value, ) (*ExecuteTask, error)
ExecuteUDFNode applies user defined function on records that match the statement filter on the specified node. Records are not returned to the client. This asynchronous server call will return before command is complete. The user can optionally wait for command completion by using the returned ExecuteTask instance.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) Exists ¶
func (clnt *Client) Exists(policy *BasePolicy, key *Key) (bool, error)
Exists determine if a record key exists. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) Get ¶
Get reads a record header and bins for specified key. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) GetHeader ¶
func (clnt *Client) GetHeader(policy *BasePolicy, key *Key) (*Record, error)
GetHeader reads a record generation and expiration only for specified key. Bins are not read. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) GetNodeNames ¶
GetNodeNames returns a list of active server node names in the cluster.
func (*Client) GetObject ¶ added in v1.4.0
func (clnt *Client) GetObject(policy *BasePolicy, key *Key, obj interface{}) error
GetObject reads a record for specified key and puts the result into the provided object. The policy can be used to specify timeouts. If the policy is nil, the default relevant policy will be used.
func (*Client) GrantPrivileges ¶ added in v1.24.0
func (clnt *Client) GrantPrivileges(policy *AdminPolicy, roleName string, privileges []Privilege) error
GrantPrivileges grant privileges to a user-defined role.
func (*Client) GrantRoles ¶ added in v1.3.0
func (clnt *Client) GrantRoles(policy *AdminPolicy, user string, roles []string) error
GrantRoles adds roles to user's list of roles.
func (*Client) IsConnected ¶
IsConnected determines if the client is ready to talk to the database server cluster.
func (*Client) ListUDF ¶ added in v1.0.1
func (clnt *Client) ListUDF(policy *BasePolicy) ([]*UDF, error)
ListUDF lists all packages containing user defined functions in the server. This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) Operate ¶ added in v1.0.1
func (clnt *Client) Operate(policy *WritePolicy, key *Key, operations ...*Operation) (*Record, error)
Operate performs multiple read/write operations on a single key in one batch request. An example would be to add an integer value to an existing record and then read the result, all in one database call.
If the policy is nil, the default relevant policy will be used.
func (*Client) Prepend ¶
func (clnt *Client) Prepend(policy *WritePolicy, key *Key, binMap BinMap) error
Prepend prepends bin value's string to existing record bin values. The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. This call works only for string and []byte values. If the policy is nil, the default relevant policy will be used.
func (*Client) PrependBins ¶
func (clnt *Client) PrependBins(policy *WritePolicy, key *Key, bins ...*Bin) error
PrependBins works the same as Prepend, but avoids BinMap allocation and iteration.
func (*Client) Put ¶
func (clnt *Client) Put(policy *WritePolicy, key *Key, binMap BinMap) error
Put writes record bin(s) to the server. The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. If the policy is nil, the default relevant policy will be used.
func (*Client) PutBins ¶
func (clnt *Client) PutBins(policy *WritePolicy, key *Key, bins ...*Bin) error
PutBins writes record bin(s) to the server. The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. This method avoids using the BinMap allocation and iteration and is lighter on GC. If the policy is nil, the default relevant policy will be used.
func (*Client) PutObject ¶ added in v1.4.0
func (clnt *Client) PutObject(policy *WritePolicy, key *Key, obj interface{}) (err error)
PutObject writes record bin(s) to the server. The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. If the policy is nil, the default relevant policy will be used. A struct can be tagged to influence the way the object is put in the database:
type Person struct { TTL uint32 `asm:"ttl"` RecGen uint32 `asm:"gen"` Name string `as:"name"` Address string `as:"desc,omitempty"` Age uint8 `as:",omitempty"` Password string `as:"-"` }
Tag `as:` denotes Aerospike fields. The first value will be the alias for the field. `,omitempty` (without any spaces between the comma and the word) will act like the json package, and will not send the value of the field to the database if the value is zero value. Tag `asm:` denotes Aerospike Meta fields, and includes ttl and generation values. If a tag is marked with `-`, it will not be sent to the database at all. Note: Tag `as` can be replaced with any other user-defined tag via the function `SetAerospikeTag`.
func (*Client) Query ¶ added in v1.0.1
func (clnt *Client) Query(policy *QueryPolicy, statement *Statement) (*Recordset, error)
Query executes a query and returns a Recordset. The query executor puts records on the channel from separate goroutines. The caller can concurrently pop records off the channel through the Recordset.Records channel.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) QueryAggregate ¶ added in v1.10.0
func (clnt *Client) QueryAggregate(policy *QueryPolicy, statement *Statement, packageName, functionName string, functionArgs ...Value) (*Recordset, error)
QueryAggregate executes a Map/Reduce query and returns the results. The query executor puts records on the channel from separate goroutines. The caller can concurrently pop records off the channel through the Recordset.Records channel.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) QueryExecute ¶
func (clnt *Client) QueryExecute(policy *QueryPolicy, writePolicy *WritePolicy, statement *Statement, ops ...*Operation, ) (*ExecuteTask, error)
QueryExecute applies operations on records that match the statement filter. Records are not returned to the client. This asynchronous server call will return before the command is complete. The user can optionally wait for command completion by using the returned ExecuteTask instance.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) QueryNode ¶ added in v1.3.0
func (clnt *Client) QueryNode(policy *QueryPolicy, node *Node, statement *Statement) (*Recordset, error)
QueryNode executes a query on a specific node and returns a recordset. The caller can concurrently pop records off the channel through the record channel.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) QueryNodeObjects ¶ added in v1.8.0
func (clnt *Client) QueryNodeObjects(policy *QueryPolicy, node *Node, statement *Statement, objChan interface{}) (*Recordset, error)
QueryNodeObjects executes a query on a specific node and marshals the records into the given channel. The caller can concurrently pop records off the channel.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) QueryObjects ¶ added in v1.8.0
func (clnt *Client) QueryObjects(policy *QueryPolicy, statement *Statement, objChan interface{}) (*Recordset, error)
QueryNodeObjects executes a query on all nodes in the cluster and marshals the records into the given channel. The query executor puts records on the channel from separate goroutines. The caller can concurrently pop objects.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) QueryRole ¶ added in v1.24.0
func (clnt *Client) QueryRole(policy *AdminPolicy, role string) (*Role, error)
QueryRole retrieves privileges for a given role.
func (*Client) QueryRoles ¶ added in v1.24.0
func (clnt *Client) QueryRoles(policy *AdminPolicy) ([]*Role, error)
QueryRoles retrieves all roles and their privileges.
func (*Client) QueryUser ¶ added in v1.3.0
func (clnt *Client) QueryUser(policy *AdminPolicy, user string) (*UserRoles, error)
QueryUser retrieves roles for a given user.
func (*Client) QueryUsers ¶ added in v1.3.0
func (clnt *Client) QueryUsers(policy *AdminPolicy) ([]*UserRoles, error)
QueryUsers retrieves all users and their roles.
func (*Client) RegisterUDF ¶ added in v1.0.1
func (clnt *Client) RegisterUDF(policy *WritePolicy, udfBody []byte, serverPath string, language Language) (*RegisterTask, error)
RegisterUDF registers a package containing user defined functions with server. This asynchronous server call will return before command is complete. The user can optionally wait for command completion by using the returned RegisterTask instance.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) RegisterUDFFromFile ¶ added in v1.0.1
func (clnt *Client) RegisterUDFFromFile(policy *WritePolicy, clientPath string, serverPath string, language Language) (*RegisterTask, error)
RegisterUDFFromFile reads a file from file system and registers the containing a package user defined functions with the server. This asynchronous server call will return before command is complete. The user can optionally wait for command completion by using the returned RegisterTask instance.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) RemoveUDF ¶ added in v1.0.1
func (clnt *Client) RemoveUDF(policy *WritePolicy, udfName string) (*RemoveTask, error)
RemoveUDF removes a package containing user defined functions in the server. This asynchronous server call will return before command is complete. The user can optionally wait for command completion by using the returned RemoveTask instance.
This method is only supported by Aerospike 3+ servers. If the policy is nil, the default relevant policy will be used.
func (*Client) RevokePrivileges ¶ added in v1.24.0
func (clnt *Client) RevokePrivileges(policy *AdminPolicy, roleName string, privileges []Privilege) error
RevokePrivileges revokes privileges from a user-defined role.
func (*Client) RevokeRoles ¶ added in v1.3.0
func (clnt *Client) RevokeRoles(policy *AdminPolicy, user string, roles []string) error
RevokeRoles removes roles from user's list of roles.
func (*Client) ScanAll ¶ added in v1.0.1
func (clnt *Client) ScanAll(apolicy *ScanPolicy, namespace string, setName string, binNames ...string) (*Recordset, error)
ScanAll reads all records in specified namespace and set from all nodes. If the policy's concurrentNodes is specified, each server node will be read in parallel. Otherwise, server nodes are read sequentially. If the policy is nil, the default relevant policy will be used.
func (*Client) ScanAllObjects ¶ added in v1.8.0
func (clnt *Client) ScanAllObjects(apolicy *ScanPolicy, objChan interface{}, namespace string, setName string, binNames ...string) (*Recordset, error)
ScanAllObjects reads all records in specified namespace and set from all nodes. If the policy's concurrentNodes is specified, each server node will be read in parallel. Otherwise, server nodes are read sequentially. If the policy is nil, the default relevant policy will be used.
func (*Client) ScanNode ¶ added in v1.0.1
func (clnt *Client) ScanNode(apolicy *ScanPolicy, node *Node, namespace string, setName string, binNames ...string) (*Recordset, error)
ScanNode reads all records in specified namespace and set for one node only. If the policy is nil, the default relevant policy will be used.
func (*Client) ScanNodeObjects ¶ added in v1.8.0
func (clnt *Client) ScanNodeObjects(apolicy *ScanPolicy, node *Node, objChan interface{}, namespace string, setName string, binNames ...string) (*Recordset, error)
scanNodeObjects reads all records in specified namespace and set for one node only, and marshalls the results into the objects of the provided channel in Recordset. If the policy is nil, the default relevant policy will be used. The resulting records will be marshalled into the objChan. objChan will be closed after all the records are read.
func (*Client) SetWhitelist ¶
func (clnt *Client) SetWhitelist(policy *AdminPolicy, roleName string, whitelist []string) error
SetWhitelist sets IP address whitelist for a role. If whitelist is nil or empty, it removes existing whitelist from role.
func (*Client) Stats ¶ added in v1.28.0
Stats returns internal statistics regarding the inner state of the client and the cluster.
func (*Client) Touch ¶
func (clnt *Client) Touch(policy *WritePolicy, key *Key) error
Touch updates a record's metadata. If the record exists, the record's TTL will be reset to the policy's expiration. If the record doesn't exist, it will return an error.
func (*Client) Truncate ¶ added in v1.26.0
func (clnt *Client) Truncate(policy *WritePolicy, namespace, set string, beforeLastUpdate *time.Time) error
Truncate removes records in specified namespace/set efficiently. This method is many orders of magnitude faster than deleting records one at a time. Works with Aerospike Server versions >= 3.12. This asynchronous server call may return before the truncation is complete. The user can still write new records after the server call returns because new records will have last update times greater than the truncate cutoff (set at the time of truncate call). For more information, See https://www.aerospike.com/docs/reference/info#truncate
func (*Client) WarmUp ¶
WarmUp fills the connection pool with connections for all nodes. This is necessary on startup for high traffic programs. If the count is <= 0, the connection queue will be filled. If the count is more than the size of the pool, the pool will be filled. Note: One connection per node is reserved for tend operations and is not used for transactions.
type ClientPolicy ¶
type ClientPolicy struct { // AuthMode specifies authentication mode used when user/password is defined. It is set to AuthModeInternal by default. AuthMode AuthMode // User authentication to cluster. Leave empty for clusters running without restricted access. User string // Password authentication to cluster. The password will be stored by the client and sent to server // in hashed format. Leave empty for clusters running without restricted access. Password string // ClusterName sets the expected cluster ID. If not null, server nodes must return this cluster ID in order to // join the client's view of the cluster. Should only be set when connecting to servers that // support the "cluster-name" info command. (v3.10+) ClusterName string //="" // Initial host connection timeout duration. The timeout when opening a connection // to the server host for the first time. Timeout time.Duration //= 30 seconds // Connection idle timeout. Every time a connection is used, its idle // deadline will be extended by this duration. When this deadline is reached, // the connection will be closed and discarded from the connection pool. // The value is limited to 24 hours (86400s). // // It's important to set this value to a few seconds less than the server's proto-fd-idle-ms // (default 60000 milliseconds or 1 minute), so the client does not attempt to use a socket // that has already been reaped by the server. // // Connection pools are now implemented by a LIFO stack. Connections at the tail of the // stack will always be the least used. These connections are checked for IdleTimeout // on every tend (usually 1 second). // // Default: 55 seconds IdleTimeout time.Duration //= 55 seconds // LoginTimeout specifies the timeout for login operation for external authentication such as LDAP. LoginTimeout time.Duration //= 10 seconds // ConnectionQueueCache specifies the size of the Connection Queue cache PER NODE. // Note: One connection per node is reserved for tend operations and is not used for transactions. ConnectionQueueSize int //= 256 // MinConnectionsPerNode specifies the minimum number of synchronous connections allowed per server node. // Preallocate min connections on client node creation. // The client will periodically allocate new connections if count falls below min connections. // // Server proto-fd-idle-ms may also need to be increased substantially if min connections are defined. // The proto-fd-idle-ms default directs the server to close connections that are idle for 60 seconds // which can defeat the purpose of keeping connections in reserve for a future burst of activity. // // If server proto-fd-idle-ms is changed, client ClientPolicy.IdleTimeout should also be // changed to be a few seconds less than proto-fd-idle-ms. // // Default: 0 MinConnectionsPerNode int // If set to true, will not create a new connection // to the node if there are already `ConnectionQueueSize` active connections. // Note: One connection per node is reserved for tend operations and is not used for transactions. LimitConnectionsToQueueSize bool //= true // Number of connections allowed to established at the same time. // This value does not limit the number of connections. It just // puts a threshold on the number of parallel opening connections. // By default, there are no limits. OpeningConnectionThreshold int // 0 // Throw exception if host connection fails during addHost(). FailIfNotConnected bool //= true // TendInterval determines interval for checking for cluster state changes. // Minimum possible interval is 10 Milliseconds. TendInterval time.Duration //= 1 second // A IP translation table is used in cases where different clients // use different server IP addresses. This may be necessary when // using clients from both inside and outside a local area // network. Default is no translation. // The key is the IP address returned from friend info requests to other servers. // The value is the real IP address used to connect to the server. IpMap map[string]string // UseServicesAlternate determines if the client should use "services-alternate" instead of "services" // in info request during cluster tending. //"services-alternate" returns server configured external IP addresses that client // uses to talk to nodes. "services-alternate" can be used in place of providing a client "ipMap". // This feature is recommended instead of using the client-side IpMap above. // // "services-alternate" is available with Aerospike Server versions >= 3.7.1. UseServicesAlternate bool // false // RackAware directs the client to update rack information on intervals. // When this feature is enabled, the client will prefer to use nodes which reside // on the same rack as the client for read transactions. The application should also set the RackId, and // use the ReplicaPolicy.PREFER_RACK for reads. // This feature is in particular useful if the cluster is in the cloud and the cloud provider // is charging for network bandwidth out of the zone. Keep in mind that the node on the same rack // may not be the Master, and as such the data may be stale. This setting is particularly usable // for clusters that are read heavy. RackAware bool // false // RackId defines the Rack the application is on. This will only influence reads if Rackaware is enabled on the client, // and configured on the server. RackId int // 0 // TlsConfig specifies TLS secure connection policy for TLS enabled servers. // For better performance, we suggest preferring the server-side ciphers by // setting PreferServerCipherSuites = true. TlsConfig *tls.Config //= nil // IgnoreOtherSubnetAliases helps to ignore aliases that are outside main subnet IgnoreOtherSubnetAliases bool //= false }
ClientPolicy encapsulates parameters for client policy command.
func NewClientPolicy ¶
func NewClientPolicy() *ClientPolicy
NewClientPolicy generates a new ClientPolicy with default values.
func (*ClientPolicy) RequiresAuthentication ¶ added in v1.3.0
func (cp *ClientPolicy) RequiresAuthentication() bool
RequiresAuthentication returns true if a User or Password is set for ClientPolicy.
type Cluster ¶
type Cluster struct {
// contains filtered or unexported fields
}
Cluster encapsulates the aerospike cluster nodes and manages them.
func NewCluster ¶
func NewCluster(policy *ClientPolicy, hosts []*Host) (*Cluster, error)
NewCluster generates a Cluster instance.
func (*Cluster) AddSeeds ¶
AddSeeds adds new hosts to the cluster. They will be added to the cluster on next tend call.
func (*Cluster) ClientPolicy ¶ added in v1.5.1
func (clstr *Cluster) ClientPolicy() (res ClientPolicy)
ClientPolicy returns the client policy that is currently used with the cluster.
func (*Cluster) Close ¶
func (clstr *Cluster) Close()
Close closes all cached connections to the cluster nodes and stops the tend goroutine.
func (*Cluster) GetAliases ¶ added in v1.23.0
GetAliases returns a list of all node aliases in the cluster
func (*Cluster) GetNodeByName ¶
GetNodeByName finds a node by name and returns an error if the node is not found.
func (*Cluster) GetRandomNode ¶
GetRandomNode returns a random node on the cluster
func (*Cluster) GetSeeds ¶ added in v1.23.0
GetSeeds returns a list of all seed nodes in the cluster
func (*Cluster) IsConnected ¶
IsConnected returns true if cluster has nodes and is not already closed.
func (*Cluster) MigrationInProgress ¶ added in v1.0.1
MigrationInProgress determines if any node in the cluster is participating in a data migration
func (*Cluster) Password ¶ added in v1.5.1
Password returns the password that is currently used with the cluster.
func (*Cluster) WaitUntillMigrationIsFinished ¶ added in v1.0.1
WaitUntillMigrationIsFinished will block until all migration operations in the cluster all finished.
func (*Cluster) WarmUp ¶
WarmUp fills the connection pool with connections for all nodes. This is necessary on startup for high traffic programs. If the count is <= 0, the connection queue will be filled. If the count is more than the size of the pool, the pool will be filled. Note: One connection per node is reserved for tend operations and is not used for transactions.
type CommitLevel ¶ added in v1.2.0
type CommitLevel int
CommitLevel indicates the desired consistency guarantee when committing a transaction on the server.
const ( // COMMIT_ALL indicates the server should wait until successfully committing master and all replicas. COMMIT_ALL CommitLevel = iota // COMMIT_MASTER indicates the server should wait until successfully committing master only. COMMIT_MASTER )
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
Connection represents a connection with a timeout.
func NewConnection ¶
func NewConnection(policy *ClientPolicy, host *Host) (*Connection, error)
NewConnection creates a TLS connection on the network and returns the pointer. A minimum timeout of 2 seconds will always be applied. If the connection is not established in the specified timeout, an error will be returned
func (*Connection) Authenticate ¶ added in v1.5.0
func (ctn *Connection) Authenticate(user string, password string) error
Authenticate will send authentication information to the server. Notice: This method does not support external authentication mechanisms like LDAP. This method is deprecated and will be removed in the future.
func (*Connection) IsConnected ¶
func (ctn *Connection) IsConnected() bool
IsConnected returns true if the connection is not closed yet.
func (*Connection) Login ¶
func (ctn *Connection) Login(policy *ClientPolicy) error
Login will send authentication information to the server. This function is provided for using the connection in conjunction with external libraries. The password will be hashed everytime, which is a slow operation.
func (*Connection) Read ¶
func (ctn *Connection) Read(buf []byte, length int) (total int, err error)
Read reads from connection buffer to the provided slice.
func (*Connection) SetTimeout ¶
SetTimeout sets connection timeout for both read and write operations.
type DropIndexTask ¶ added in v1.17.0
type DropIndexTask struct {
// contains filtered or unexported fields
}
DropIndexTask is used to poll for long running create index completion.
func NewDropIndexTask ¶ added in v1.17.0
func NewDropIndexTask(cluster *Cluster, namespace string, indexName string) *DropIndexTask
NewDropIndexTask initializes a task with fields needed to query server nodes.
func (*DropIndexTask) IsDone ¶ added in v1.17.0
func (tski *DropIndexTask) IsDone() (bool, error)
IsDone queries all nodes for task completion status.
func (*DropIndexTask) OnComplete ¶ added in v1.17.0
func (tski *DropIndexTask) OnComplete() chan error
OnComplete returns a channel that will be closed as soon as the task is finished. If an error is encountered during operation, an error will be sent on the channel.
type ExecuteTask ¶ added in v1.0.1
type ExecuteTask struct {
// contains filtered or unexported fields
}
ExecuteTask is used to poll for long running server execute job completion.
func NewExecuteTask ¶ added in v1.0.1
func NewExecuteTask(cluster *Cluster, statement *Statement) *ExecuteTask
NewExecuteTask initializes task with fields needed to query server nodes.
func (*ExecuteTask) IsDone ¶ added in v1.0.1
func (etsk *ExecuteTask) IsDone() (bool, error)
IsDone queries all nodes for task completion status.
func (*ExecuteTask) OnComplete ¶ added in v1.0.1
func (etsk *ExecuteTask) OnComplete() chan error
OnComplete returns a channel which will be closed when the task is completed. If an error is encountered while performing the task, an error will be sent on the channel.
type FieldType ¶
type FieldType int
FieldType represents the type of the field in Aerospike Wire Protocol
const ( NAMESPACE FieldType = 0 TABLE FieldType = 1 KEY FieldType = 2 DIGEST_RIPE FieldType = 4 DIGEST_RIPE_ARRAY FieldType = 6 TRAN_ID FieldType = 7 // user supplied transaction id, which is simply passed back SCAN_OPTIONS FieldType = 8 SCAN_TIMEOUT FieldType = 9 RECORDS_PER_SECOND FieldType = 10 INDEX_NAME FieldType = 21 INDEX_RANGE FieldType = 22 INDEX_FILTER FieldType = 23 INDEX_LIMIT FieldType = 24 INDEX_ORDER_BY FieldType = 25 INDEX_TYPE = 26 UDF_PACKAGE_NAME FieldType = 30 UDF_FUNCTION FieldType = 31 UDF_ARGLIST FieldType = 32 UDF_OP FieldType = 33 QUERY_BINLIST FieldType = 40 BATCH_INDEX FieldType = 41 BATCH_INDEX_WITH_SET FieldType = 42 PREDEXP FieldType = 43 )
FieldType constants used in the Aerospike Wire Protocol.
type Filter ¶ added in v1.0.1
type Filter struct {
// contains filtered or unexported fields
}
Filter specifies a query filter definition.
func NewContainsFilter ¶ added in v1.7.0
func NewContainsFilter(binName string, indexCollectionType IndexCollectionType, value interface{}) *Filter
NewContainsFilter creates a contains filter for query on collection index.
func NewContainsRangeFilter ¶ added in v1.7.0
func NewContainsRangeFilter(binName string, indexCollectionType IndexCollectionType, begin, end int64) *Filter
NewContainsRangeFilter creates a contains filter for query on ranges of data in a collection index.
func NewEqualFilter ¶ added in v1.0.1
NewEqualFilter creates a new equality filter instance for query.
func NewGeoRegionsContainingPointFilter ¶ added in v1.9.0
NewGeoRegionsContainingPointFilter creates a geospatial "containing point" filter for query. Argument must be a valid GeoJSON point.
func NewGeoRegionsContainingPointForCollectionFilter ¶ added in v1.13.0
func NewGeoRegionsContainingPointForCollectionFilter(binName string, collectionType IndexCollectionType, point string) *Filter
NewGeoRegionsContainingPointForCollectionFilter creates a geospatial "containing point" filter for query on collection index. Argument must be a valid GeoJSON point.
func NewGeoWithinRadiusFilter ¶ added in v1.9.0
NewGeoWithinRadiusFilter creates a geospatial "within radius" filter for query. Arguments must be valid longitude/latitude/radius (meters) values.
func NewGeoWithinRadiusForCollectionFilter ¶ added in v1.13.0
func NewGeoWithinRadiusForCollectionFilter(binName string, collectionType IndexCollectionType, lng, lat, radius float64) *Filter
NewGeoWithinRadiusForCollectionFilter creates a geospatial "within radius" filter for query on collection index. Arguments must be valid longitude/latitude/radius (meters) values.
func NewGeoWithinRegionFilter ¶ added in v1.9.0
NewGeoWithinRegionFilter creates a geospatial "within region" filter for query. Argument must be a valid GeoJSON region.
func NewGeoWithinRegionForCollectionFilter ¶ added in v1.13.0
func NewGeoWithinRegionForCollectionFilter(binName string, collectionType IndexCollectionType, region string) *Filter
NewGeoWithinRegionForCollectionFilter creates a geospatial "within region" filter for query on collection index. Argument must be a valid GeoJSON region.
func NewRangeFilter ¶ added in v1.0.1
NewRangeFilter creates a range filter for query. Range arguments must be int64 values. String ranges are not supported.
func (*Filter) EstimateSize ¶
func (*Filter) IndexCollectionType ¶ added in v1.7.0
func (fltr *Filter) IndexCollectionType() IndexCollectionType
IndexType return filter's index type.
type FloatValue ¶ added in v1.7.0
type FloatValue float64
FloatValue encapsulates an float64 value.
func NewFloatValue ¶ added in v1.7.0
func NewFloatValue(value float64) FloatValue
NewFloatValue generates a FloatValue instance.
func (FloatValue) EstimateSize ¶
func (vl FloatValue) EstimateSize() (int, error)
func (FloatValue) GetObject ¶ added in v1.7.0
func (vl FloatValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (FloatValue) GetType ¶ added in v1.7.0
func (vl FloatValue) GetType() int
GetType returns wire protocol value type.
func (FloatValue) String ¶ added in v1.7.0
func (vl FloatValue) String() string
String implements Stringer interface.
type GenerationPolicy ¶
type GenerationPolicy int
GenerationPolicy determines how to handle record writes based on record generation.
const ( // NONE means: Do not use record generation to restrict writes. NONE GenerationPolicy = iota // EXPECT_GEN_EQUAL means: Update/Delete record if expected generation is equal to server generation. Otherwise, fail. EXPECT_GEN_EQUAL // EXPECT_GEN_GT means: Update/Delete record if expected generation greater than the server generation. Otherwise, fail. // This is useful for restore after backup. EXPECT_GEN_GT )
type GeoJSONValue ¶ added in v1.7.0
type GeoJSONValue string
GeoJSONValue encapsulates a 2D Geo point. Supported by Aerospike 3.6.1 servers and later only.
func NewGeoJSONValue ¶ added in v1.7.0
func NewGeoJSONValue(value string) GeoJSONValue
NewMapValue generates a GeoJSONValue instance.
func (GeoJSONValue) EstimateSize ¶
func (vl GeoJSONValue) EstimateSize() (int, error)
func (GeoJSONValue) GetObject ¶ added in v1.7.0
func (vl GeoJSONValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (GeoJSONValue) GetType ¶ added in v1.7.0
func (vl GeoJSONValue) GetType() int
GetType returns wire protocol value type.
func (GeoJSONValue) String ¶ added in v1.7.0
func (vl GeoJSONValue) String() string
String implements Stringer interface.
type HLLPolicy ¶
type HLLPolicy struct {
// contains filtered or unexported fields
}
HLLPolicy determines the HyperLogLog operation policy.
func DefaultHLLPolicy ¶
func DefaultHLLPolicy() *HLLPolicy
DefaultHLLPolicy uses the default policy when performing HLL operations.
func NewHLLPolicy ¶
NewHLLPolicy uses specified HLLWriteFlags when performing HLL operations.
type HLLValue ¶
type HLLValue []byte
HLLValue encapsulates a HyperLogLog value.
func NewHLLValue ¶
NewHLLValue generates a ByteValue instance.
func (HLLValue) EstimateSize ¶
func (HLLValue) GetObject ¶
func (vl HLLValue) GetObject() interface{}
GetObject returns original value as an interface{}.
type Host ¶
type Host struct { // Host name or IP address of database server. Name string //TLSName defines the TLS certificate name used for secure connections. TLSName string // Port of database server. Port int }
Host name/port of database server.
type IndexCollectionType ¶ added in v1.7.0
type IndexCollectionType int
IndexCollectionType is the secondary index collection type.
const ( // Normal scalar index. ICT_DEFAULT IndexCollectionType = iota // LIST is Index list elements. ICT_LIST // MAPKEYS is Index map keys. ICT_MAPKEYS // MAPVALUES is Index map values. ICT_MAPVALUES )
type IndexTask ¶ added in v1.0.1
type IndexTask struct {
// contains filtered or unexported fields
}
IndexTask is used to poll for long running create index completion.
func NewIndexTask ¶ added in v1.0.1
NewIndexTask initializes a task with fields needed to query server nodes.
func (*IndexTask) OnComplete ¶ added in v1.0.1
OnComplete returns a channel that will be closed as soon as the task is finished. If an error is encountered during operation, an error will be sent on the channel.
type InfinityValue ¶ added in v1.37.0
type InfinityValue struct{}
InfinityValue is an empty value.
func NewInfinityValue ¶ added in v1.37.0
func NewInfinityValue() InfinityValue
NewInfinityValue generates a InfinityValue instance.
func (InfinityValue) EstimateSize ¶
func (vl InfinityValue) EstimateSize() (int, error)
func (InfinityValue) GetObject ¶ added in v1.37.0
func (vl InfinityValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (InfinityValue) GetType ¶ added in v1.37.0
func (vl InfinityValue) GetType() int
GetType returns wire protocol value type.
func (InfinityValue) String ¶ added in v1.37.0
func (vl InfinityValue) String() string
type InfoPolicy ¶
type InfoPolicy struct { // Info command socket timeout. // Default is 2 seconds. Timeout time.Duration }
InfoPolicy contains attributes used for info commands.
func NewInfoPolicy ¶
func NewInfoPolicy() *InfoPolicy
NewInfoPolicy generates a new InfoPolicy with default values.
type IntegerValue ¶
type IntegerValue int
IntegerValue encapsulates an integer value.
func NewIntegerValue ¶
func NewIntegerValue(value int) IntegerValue
NewIntegerValue generates an IntegerValue instance.
func (IntegerValue) EstimateSize ¶
func (vl IntegerValue) EstimateSize() (int, error)
func (IntegerValue) GetObject ¶
func (vl IntegerValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (IntegerValue) GetType ¶
func (vl IntegerValue) GetType() int
GetType returns wire protocol value type.
func (IntegerValue) String ¶
func (vl IntegerValue) String() string
String implements Stringer interface.
type JsonValue ¶ added in v1.20.0
type JsonValue map[string]interface{}
JsonValue encapsulates a Json map. Supported by Aerospike 3+ servers only.
func NewJsonValue ¶ added in v1.20.0
NewMapValue generates a JsonValue instance.
func (JsonValue) EstimateSize ¶
func (JsonValue) GetObject ¶ added in v1.20.0
func (vl JsonValue) GetObject() interface{}
GetObject returns original value as an interface{}.
type Key ¶
type Key struct {
// contains filtered or unexported fields
}
Key is the unique record identifier. Records can be identified using a specified namespace, an optional set name, and a user defined key which must be unique within a set. Records can also be identified by namespace/digest which is the combination used on the server.
func NewKey ¶
NewKey initializes a key from namespace, optional set name and user key. The set name and user defined key are converted to a digest before sending to the server. The server handles record identifiers by digest only.
func NewKeyWithDigest ¶ added in v1.2.0
func NewKeyWithDigest(namespace string, setName string, key interface{}, digest []byte) (*Key, error)
NewKeyWithDigest initializes a key from namespace, optional set name and user key. The server handles record identifiers by digest only.
func (*Key) SetValue ¶ added in v1.25.0
SetValue sets the Key's value and recompute's its digest without allocating new memory. This allows the keys to be reusable.
type Language ¶ added in v1.0.1
type Language string
Language specifies User defined function languages.
const ( // LUA embedded programming language. LUA Language = "LUA" )
type ListIter ¶ added in v1.20.0
ListIter allows to define general maps of your own type to be used in the Go client without the use of reflection. function PackList should be exactly Like the following (Do not change, just copy/paste and adapt PackXXX methods):
func (cs *CustomSlice) PackList(buf aerospike.BufferEx) (int, error) { size := 0 for _, elem := range cs { n, err := PackXXX(buf, elem) size += n if err != nil { return size, err } } return size, nil }
Example (Int) ¶
package main import ( "fmt" "log" as "github.com/aerospike/aerospike-client-go" ) /* myListInt */ var _ as.ListIter = myListInt([]int{}) // your custom list type myListInt []int func (ml myListInt) PackList(buf as.BufferEx) (int, error) { size := 0 for _, elem := range ml { n, err := as.PackInt64(buf, int64(elem)) size += n if err != nil { return size, err } } return size, nil } func (ml myListInt) Len() int { return len(ml) } func main() { // Setup the client here // client, err := as.NewClient("127.0.0.1", 3000) // if err != nil { // log.Fatal(err) // } var v as.Value = as.NewValue(myListInt([]int{1, 2, 3})) key, err := as.NewKey("test", "test", 1) if err != nil { log.Fatal(err) } err = client.Put(nil, key, as.BinMap{"myBin": v}) if err != nil { log.Fatal(err) } rec, err := client.Get(nil, key) if err != nil { log.Fatal(err) } fmt.Println(rec.Bins["myBin"]) }
Output: [1 2 3]
Example (String) ¶
package main import ( "fmt" "log" as "github.com/aerospike/aerospike-client-go" ) /* myListString */ var _ as.ListIter = myListString([]string{}) // your custom list type myListString []string func (ml myListString) PackList(buf as.BufferEx) (int, error) { size := 0 for _, elem := range ml { n, err := as.PackString(buf, elem) size += n if err != nil { return size, err } } return size, nil } func (ml myListString) Len() int { return len(ml) } func main() { // Setup the client here // client, err := as.NewClient("127.0.0.1", 3000) // if err != nil { // log.Fatal(err) // } var v as.Value = as.NewValue(myListString([]string{"a", "b", "c"})) key, err := as.NewKey("test", "test", 1) if err != nil { log.Fatal(err) } err = client.Put(nil, key, as.BinMap{"myBin": v}) if err != nil { log.Fatal(err) } rec, err := client.Get(nil, key) if err != nil { log.Fatal(err) } fmt.Println(rec.Bins["myBin"]) }
Output: [a b c]
Example (Time) ¶
package main import ( "fmt" "log" "time" as "github.com/aerospike/aerospike-client-go" ) /* myListTime */ var _ as.ListIter = myListTime([]time.Time{}) // your custom list type myListTime []time.Time func (ml myListTime) PackList(buf as.BufferEx) (int, error) { size := 0 for _, elem := range ml { n, err := as.PackInt64(buf, elem.UnixNano()) size += n if err != nil { return size, err } } return size, nil } func (ml myListTime) Len() int { return len(ml) } func main() { // Setup the client here // client, err := as.NewClient("127.0.0.1", 3000) // if err != nil { // log.Fatal(err) // } now1 := time.Unix(123123123, 0) now2 := time.Unix(123123124, 0) now3 := time.Unix(123123125, 0) var v as.Value = as.NewValue(myListTime([]time.Time{now1, now2, now3})) key, err := as.NewKey("test", "test", 1) if err != nil { log.Fatal(err) } err = client.Put(nil, key, as.BinMap{"myBin": v}) if err != nil { log.Fatal(err) } rec, err := client.Get(nil, key) if err != nil { log.Fatal(err) } fmt.Println(rec.Bins["myBin"]) }
Output: [123123123000000000 123123124000000000 123123125000000000]
type ListOrderType ¶ added in v1.33.0
type ListOrderType int
ListOrderType determines the order of returned values in CDT list operations.
const ( // ListOrderUnordered signifies that list is not ordered. This is the default. ListOrderUnordered ListOrderType = 0 // ListOrderOrdered signifies that list is Ordered. ListOrderOrdered ListOrderType = 1 )
Map storage order.
type ListPolicy ¶ added in v1.33.0
type ListPolicy struct {
// contains filtered or unexported fields
}
ListPolicy directives when creating a list and writing list items.
func DefaultListPolicy ¶ added in v1.33.0
func DefaultListPolicy() *ListPolicy
DefaultListPolicy returns the default policy for CDT list operations.
func NewListPolicy ¶ added in v1.33.0
func NewListPolicy(order ListOrderType, flags int) *ListPolicy
Create unique key map with specified order when map does not exist. Use specified write mode when writing map items.
type ListReturnType ¶ added in v1.33.0
type ListReturnType int
ListReturnType determines the returned values in CDT List operations.
const ( // Do not return a result. ListReturnTypeNone ListReturnType = 0 // Return index offset order. // 0 = first key // N = Nth key // -1 = last key ListReturnTypeIndex ListReturnType = 1 // Return reverse index offset order. // 0 = last key // -1 = first key ListReturnTypeReverseIndex ListReturnType = 2 // Return value order. // 0 = smallest value // N = Nth smallest value // -1 = largest value ListReturnTypeRank ListReturnType = 3 // Return reserve value order. // 0 = largest value // N = Nth largest value // -1 = smallest value ListReturnTypeReverseRank ListReturnType = 4 // Return count of items selected. ListReturnTypeCount ListReturnType = 5 // Return value for single key read and value list for range read. ListReturnTypeValue ListReturnType = 7 // Invert meaning of list command and return values. For example: // ListOperation.getByIndexRange(binName, index, count, ListReturnType.INDEX | ListReturnType.INVERTED) // With the INVERTED flag enabled, the items outside of the specified index range will be returned. // The meaning of the list command can also be inverted. For example: // ListOperation.removeByIndexRange(binName, index, count, ListReturnType.INDEX | ListReturnType.INVERTED); // With the INVERTED flag enabled, the items outside of the specified index range will be removed and returned. ListReturnTypeInverted ListReturnType = 0x10000 )
type ListValue ¶
type ListValue []interface{}
ListValue encapsulates any arbitrary array. Supported by Aerospike 3+ servers only.
func NewListValue ¶
func NewListValue(list []interface{}) ListValue
NewListValue generates a ListValue instance.
func (ListValue) EstimateSize ¶
func (ListValue) GetObject ¶
func (vl ListValue) GetObject() interface{}
GetObject returns original value as an interface{}.
type ListerValue ¶ added in v1.20.0
type ListerValue struct {
// contains filtered or unexported fields
}
ListerValue encapsulates any arbitrary array. Supported by Aerospike 3+ servers only.
func NewListerValue ¶ added in v1.20.0
func NewListerValue(list ListIter) *ListerValue
NewListValue generates a ListValue instance.
func (*ListerValue) EstimateSize ¶
func (vl *ListerValue) EstimateSize() (int, error)
func (*ListerValue) GetObject ¶ added in v1.20.0
func (vl *ListerValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (*ListerValue) GetType ¶ added in v1.20.0
func (vl *ListerValue) GetType() int
GetType returns wire protocol value type.
func (*ListerValue) String ¶ added in v1.20.0
func (vl *ListerValue) String() string
String implements Stringer interface.
type LongValue ¶
type LongValue int64
LongValue encapsulates an int64 value.
func NewLongValue ¶
NewLongValue generates a LongValue instance.
func (LongValue) EstimateSize ¶
func (LongValue) GetObject ¶
func (vl LongValue) GetObject() interface{}
GetObject returns original value as an interface{}.
type MapIter ¶ added in v1.20.0
n, err = PackXXX(buf, v) size += n if err != nil { return size, err } } return size, nil }
Example ¶
package main import ( "fmt" "log" "time" as "github.com/aerospike/aerospike-client-go" ) /* myMapStringTime */ var _ as.MapIter = myMapStringTime(map[string]time.Time{}) // your custom list type myMapStringTime map[string]time.Time func (mm myMapStringTime) PackMap(buf as.BufferEx) (int, error) { size := 0 for key, val := range mm { n, err := as.PackString(buf, key) size += n if err != nil { return size, err } n, err = as.PackInt64(buf, val.UnixNano()) size += n if err != nil { return size, err } } return size, nil } func (mm myMapStringTime) Len() int { return len(mm) } func main() { // Setup the client here // client, err := as.NewClient("127.0.0.1", 3000) // if err != nil { // log.Fatal(err) // } now := time.Unix(123123123, 0) var v as.Value = as.NewValue(myMapStringTime(map[string]time.Time{"now": now})) key, err := as.NewKey("test", "test", 1) if err != nil { log.Fatal(err) } err = client.Put(nil, key, as.BinMap{"myBin": v}) if err != nil { log.Fatal(err) } rec, err := client.Get(nil, key) if err != nil { log.Fatal(err) } fmt.Println(rec.Bins["myBin"]) }
Output: map[now:123123123000000000]
type MapPair ¶ added in v1.16.0
type MapPair struct{ Key, Value interface{} }
Map pair is used when the client returns sorted maps from the server Since the default map in Go is a hash map, we will use a slice to return the results in server order
type MapPolicy ¶ added in v1.16.0
type MapPolicy struct {
// contains filtered or unexported fields
}
MapPolicy directives when creating a map and writing map items.
func DefaultMapPolicy ¶ added in v1.16.0
func DefaultMapPolicy() *MapPolicy
DefaultMapPolicy returns the default map policy
func NewMapPolicy ¶ added in v1.16.0
func NewMapPolicy(order mapOrderType, writeMode *mapWriteMode) *MapPolicy
NewMapPolicy creates a MapPolicy with WriteMode. Use with servers before v4.3
func NewMapPolicyWithFlags ¶ added in v1.35.0
NewMapPolicyWithFlags creates a MapPolicy with WriteFlags. Use with servers v4.3+
type MapValue ¶
type MapValue map[interface{}]interface{}
MapValue encapsulates an arbitrary map. Supported by Aerospike 3+ servers only.
func NewMapValue ¶
func NewMapValue(vmap map[interface{}]interface{}) MapValue
NewMapValue generates a MapValue instance.
func (MapValue) EstimateSize ¶
func (MapValue) GetObject ¶
func (vl MapValue) GetObject() interface{}
GetObject returns original value as an interface{}.
type MapperValue ¶ added in v1.20.0
type MapperValue struct {
// contains filtered or unexported fields
}
MapperValue encapsulates an arbitrary map which implements a MapIter interface. Supported by Aerospike 3+ servers only.
func NewMapperValue ¶ added in v1.20.0
func NewMapperValue(vmap MapIter) *MapperValue
NewMapValue generates a MapperValue instance.
func (*MapperValue) EstimateSize ¶
func (vl *MapperValue) EstimateSize() (int, error)
func (*MapperValue) GetObject ¶ added in v1.20.0
func (vl *MapperValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (*MapperValue) GetType ¶ added in v1.20.0
func (vl *MapperValue) GetType() int
GetType returns wire protocol value type.
func (*MapperValue) String ¶ added in v1.20.0
func (vl *MapperValue) String() string
type MultiPolicy ¶ added in v1.0.2
type MultiPolicy struct { BasePolicy // Maximum number of concurrent requests to server nodes at any point in time. // If there are 16 nodes in the cluster and maxConcurrentNodes is 8, then queries // will be made to 8 nodes in parallel. When a query completes, a new query will // be issued until all 16 nodes have been queried. // Default (0) is to issue requests to all server nodes in parallel. MaxConcurrentNodes int // FailOnClusterChange determines scan termination if cluster is in fluctuating state. FailOnClusterChange bool // RecordsPerSecond limits returned records per second (rps) rate for each server. // Will not apply rps limit if recordsPerSecond is zero (default). // Currently only applicable to a query without a defined filter. RecordsPerSecond int // Number of records to place in queue before blocking. // Records received from multiple server nodes will be placed in a queue. // A separate goroutine consumes these records in parallel. // If the queue is full, the producer goroutines will block until records are consumed. RecordQueueSize int //= 50 // Indicates if bin data is retrieved. If false, only record digests are retrieved. IncludeBinData bool //= true; }
MultiPolicy contains parameters for policy attributes used in query and scan operations.
func NewMultiPolicy ¶ added in v1.0.2
func NewMultiPolicy() *MultiPolicy
NewMultiPolicy initializes a MultiPolicy instance with default values.
type Node ¶
type Node struct {
// contains filtered or unexported fields
}
Node represents an Aerospike Database Server Node
func GetNodeBatchRead ¶
func GetNodeBatchRead(cluster *Cluster, key *Key, replica ReplicaPolicy, replicaSC ReplicaPolicy, sequence int, sequenceSC int) (*Node, error)
GetNodeBatchRead returns a node for batch reads
func (*Node) Close ¶
func (nd *Node) Close()
Close marks node as inactive and closes all of its pooled connections.
func (*Node) GetConnection ¶
func (nd *Node) GetConnection(timeout time.Duration) (conn *Connection, err error)
GetConnection gets a connection to the node. If no pooled connection is available, a new connection will be created, unless ClientPolicy.MaxQueueSize number of connections are already created. This method will retry to retrieve a connection in case the connection pool is empty, until timeout is reached.
func (*Node) InvalidateConnection ¶ added in v1.6.0
func (nd *Node) InvalidateConnection(conn *Connection)
InvalidateConnection closes and discards a connection from the pool.
func (*Node) MigrationInProgress ¶ added in v1.0.1
MigrationInProgress determines if the node is participating in a data migration
func (*Node) PutConnection ¶
func (nd *Node) PutConnection(conn *Connection)
PutConnection puts back a connection to the pool. If connection pool is full, the connection will be closed and discarded.
func (*Node) Refresh ¶
Refresh requests current status from server node, and updates node with the result.
func (*Node) RequestInfo ¶ added in v1.12.0
RequestInfo gets info values by name from the specified database server node.
func (*Node) RequestStats ¶
func (node *Node) RequestStats(policy *InfoPolicy) (map[string]string, error)
RequestStats returns statistics for the specified node as a map
func (*Node) WaitUntillMigrationIsFinished ¶ added in v1.0.1
WaitUntillMigrationIsFinished will block until migration operations are finished.
func (*Node) WarmUp ¶
WarmUp fills the node's connection pool with connections. This is necessary on startup for high traffic programs. If the count is <= 0, the connection queue will be filled. If the count is more than the size of the pool, the pool will be filled. Note: One connection per node is reserved for tend operations and is not used for transactions.
type NodeError ¶ added in v1.0.1
type NodeError struct {
// contains filtered or unexported fields
}
NodeError is a type to encapsulate the node that the error occurred in.
type NullValue ¶
type NullValue struct{}
NullValue is an empty value.
func NewNullValue ¶ added in v1.0.1
func NewNullValue() NullValue
NewNullValue generates a NullValue instance.
func (NullValue) EstimateSize ¶
func (NullValue) GetObject ¶
func (vl NullValue) GetObject() interface{}
GetObject returns original value as an interface{}.
type Operation ¶
type Operation struct {
// contains filtered or unexported fields
}
Operation contains operation definition. This struct is used in client's operate() method.
func BitAddOp ¶
func BitAddOp( policy *BitPolicy, binName string, bitOffset int, bitSize int, value int64, signed bool, action BitOverflowAction, ctx ...*CDTContext, ) *Operation
BitAddOp creates bit "add" operation. Server adds value to byte[] bin starting at bitOffset for bitSize. BitSize must be <= 64. Signed indicates if bits should be treated as a signed number. If add overflows/underflows, {@link BitOverflowAction} is used. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 24 bitSize = 16 value = 128 signed = false bin result = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b10000101]
func BitAndOp ¶
func BitAndOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ctx ...*CDTContext) *Operation
BitAndOp creates bit "and" operation. Server performs bitwise "and" on value and byte[] bin at bitOffset for bitSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 23 bitSize = 9 value = [0b00111100, 0b10000000] bin result = [0b00000001, 0b01000010, 0b00000010, 0b00000000, 0b00000101]
func BitCountOp ¶
func BitCountOp(binName string, bitOffset int, bitSize int, ctx ...*CDTContext) *Operation
BitCountOp creates bit "count" operation. Server returns integer count of set bits from byte[] bin starting at bitOffset for bitSize. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 20 bitSize = 4 returns 2
func BitGetIntOp ¶
func BitGetIntOp(binName string, bitOffset int, bitSize int, signed bool, ctx ...*CDTContext) *Operation
BitGetIntOp creates bit "get integer" operation. Server returns integer from byte[] bin starting at bitOffset for bitSize. Signed indicates if bits should be treated as a signed number. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 8 bitSize = 16 signed = false returns 16899
func BitGetOp ¶
func BitGetOp(binName string, bitOffset int, bitSize int, ctx ...*CDTContext) *Operation
BitGetOp creates bit "get" operation. Server returns bits from byte[] bin starting at bitOffset for bitSize. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 9 bitSize = 5 returns [0b1000000]
func BitInsertOp ¶
func BitInsertOp(policy *BitPolicy, binName string, byteOffset int, value []byte, ctx ...*CDTContext) *Operation
BitInsertOp creates byte "insert" operation. Server inserts value bytes into byte[] bin at byteOffset. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] byteOffset = 1 value = [0b11111111, 0b11000111] bin result = [0b00000001, 0b11111111, 0b11000111, 0b01000010, 0b00000011, 0b00000100, 0b00000101]
func BitLScanOp ¶
func BitLScanOp(binName string, bitOffset int, bitSize int, value bool, ctx ...*CDTContext) *Operation
BitLScanOp creates bit "left scan" operation. Server returns integer bit offset of the first specified value bit in byte[] bin starting at bitOffset for bitSize. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 24 bitSize = 8 value = true returns 5
func BitLShiftOp ¶
func BitLShiftOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, shift int, ctx ...*CDTContext) *Operation
BitLShiftOp creates bit "left shift" operation. Server shifts left byte[] bin starting at bitOffset for bitSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 32 bitSize = 8 shift = 3 bin result = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00101000]
func BitNotOp ¶
func BitNotOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, ctx ...*CDTContext) *Operation
BitNotOp creates bit "not" operation. Server negates byte[] bin starting at bitOffset for bitSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 25 bitSize = 6 bin result = [0b00000001, 0b01000010, 0b00000011, 0b01111010, 0b00000101]
func BitOrOp ¶
func BitOrOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ctx ...*CDTContext) *Operation
BitOrOp creates bit "or" operation. Server performs bitwise "or" on value and byte[] bin at bitOffset for bitSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 17 bitSize = 6 value = [0b10101000] bin result = [0b00000001, 0b01000010, 0b01010111, 0b00000100, 0b00000101]
func BitRScanOp ¶
func BitRScanOp(binName string, bitOffset int, bitSize int, value bool, ctx ...*CDTContext) *Operation
BitRScanOp creates bit "right scan" operation. Server returns integer bit offset of the last specified value bit in byte[] bin starting at bitOffset for bitSize. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 32 bitSize = 8 value = true returns 7
func BitRShiftOp ¶
func BitRShiftOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, shift int, ctx ...*CDTContext) *Operation
BitRShiftOp creates bit "right shift" operation. Server shifts right byte[] bin starting at bitOffset for bitSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 0 bitSize = 9 shift = 1 bin result = [0b00000000, 0b11000010, 0b00000011, 0b00000100, 0b00000101]
func BitRemoveOp ¶
func BitRemoveOp(policy *BitPolicy, binName string, byteOffset int, byteSize int, ctx ...*CDTContext) *Operation
BitRemoveOp creates byte "remove" operation. Server removes bytes from byte[] bin at byteOffset for byteSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] byteOffset = 2 byteSize = 3 bin result = [0b00000001, 0b01000010]
func BitResizeOp ¶
func BitResizeOp(policy *BitPolicy, binName string, byteSize int, resizeFlags int, ctx ...*CDTContext) *Operation
BitResizeOp creates byte "resize" operation. Server resizes byte[] to byteSize according to resizeFlags (See {@link BitResizeFlags}). Server does not return a value. Example: bin = [0b00000001, 0b01000010] byteSize = 4 resizeFlags = 0 bin result = [0b00000001, 0b01000010, 0b00000000, 0b00000000]
func BitSetIntOp ¶
func BitSetIntOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value int64, ctx ...*CDTContext) *Operation
BitSetIntOp creates bit "setInt" operation. Server sets value to byte[] bin starting at bitOffset for bitSize. Size must be <= 64. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 1 bitSize = 8 value = 127 bin result = [0b00111111, 0b11000010, 0b00000011, 0b0000100, 0b00000101]
func BitSetOp ¶
func BitSetOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ctx ...*CDTContext) *Operation
BitSetOp creates bit "set" operation. Server sets value on byte[] bin at bitOffset for bitSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 13 bitSize = 3 value = [0b11100000] bin result = [0b00000001, 0b01000111, 0b00000011, 0b00000100, 0b00000101]
func BitSubtractOp ¶
func BitSubtractOp( policy *BitPolicy, binName string, bitOffset int, bitSize int, value int64, signed bool, action BitOverflowAction, ctx ...*CDTContext, ) *Operation
BitSubtractOp creates bit "subtract" operation. Server subtracts value from byte[] bin starting at bitOffset for bitSize. BitSize must be <= 64. Signed indicates if bits should be treated as a signed number. If add overflows/underflows, {@link BitOverflowAction} is used. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 24 bitSize = 16 value = 128 signed = false bin result = [0b00000001, 0b01000010, 0b00000011, 0b0000011, 0b10000101]
func BitXorOp ¶
func BitXorOp(policy *BitPolicy, binName string, bitOffset int, bitSize int, value []byte, ctx ...*CDTContext) *Operation
BitXorOp creates bit "exclusive or" operation. Server performs bitwise "xor" on value and byte[] bin at bitOffset for bitSize. Server does not return a value. Example: bin = [0b00000001, 0b01000010, 0b00000011, 0b00000100, 0b00000101] bitOffset = 17 bitSize = 6 value = [0b10101100] bin result = [0b00000001, 0b01000010, 0b01010101, 0b00000100, 0b00000101]
func GetHeaderOp ¶ added in v1.0.1
func GetHeaderOp() *Operation
GetHeaderOp creates read record header database operation.
func GetOp ¶ added in v1.0.1
func GetOp() *Operation
GetOp creates read all record bins database operation.
func GetOpForBin ¶ added in v1.0.1
GetOpForBin creates read bin database operation.
func HLLAddOp ¶
func HLLAddOp(policy *HLLPolicy, binName string, list []Value, indexBitCount, minHashBitCount int) *Operation
HLLAddOp creates HLL add operation with minhash bits. Server adds values to HLL set. If HLL bin does not exist, use indexBitCount and minHashBitCount to create HLL bin. Server returns number of entries that caused HLL to update a register.
policy write policy, use DefaultHLLPolicy for default binName name of bin list list of values to be added indexBitCount number of index bits. Must be between 4 and 16 inclusive. Pass -1 for default. minHashBitCount number of min hash bits. Must be between 4 and 58 inclusive. Pass -1 for default.
func HLLDescribeOp ¶
Create HLL describe operation. Server returns indexBitCount and minHashBitCount used to create HLL bin in a list of longs. The list size is 2.
binName name of bin
func HLLFoldOp ¶
Create HLL fold operation. Servers folds indexBitCount to the specified value. This can only be applied when minHashBitCount on the HLL bin is 0. Server does not return a value.
binName name of bin indexBitCount number of index bits. Must be between 4 and 16 inclusive.
func HLLGetCountOp ¶
Create HLL getCount operation. Server returns estimated number of elements in the HLL bin.
binName name of bin
func HLLGetIntersectCountOp ¶
Create HLL getIntersectCount operation. Server returns estimated number of elements that would be contained by the intersection of these HLL objects.
binName name of bin list list of HLL objects
func HLLGetSimilarityOp ¶
Create HLL getSimilarity operation. Server returns estimated similarity of these HLL objects. Return type is a double.
binName name of bin list list of HLL objects
func HLLGetUnionCountOp ¶
Create HLL getUnionCount operation. Server returns estimated number of elements that would be contained by the union of these HLL objects.
binName name of bin list list of HLL objects
func HLLGetUnionOp ¶
Create HLL getUnion operation. Server returns an HLL object that is the union of all specified HLL objects in the list with the HLL bin.
binName name of bin list list of HLL objects
func HLLInitOp ¶
HLLInitOp creates HLL init operation with minhash bits. Server creates a new HLL or resets an existing HLL. Server does not return a value.
policy write policy, use DefaultHLLPolicy for default binName name of bin indexBitCount number of index bits. Must be between 4 and 16 inclusive. Pass -1 for default. minHashBitCount number of min hash bits. Must be between 4 and 58 inclusive. Pass -1 for default.
func HLLRefreshCountOp ¶
Create HLL refresh operation. Server updates the cached count (if stale) and returns the count.
binName name of bin
func HLLSetUnionOp ¶
Create HLL set union operation. Server sets union of specified HLL objects with HLL bin. Server does not return a value.
policy write policy, use DefaultHLLPolicy for default binName name of bin list list of HLL objects
func ListAppendOp ¶ added in v1.9.0
ListAppendOp creates a list append operation. Server appends values to end of list bin. Server returns list size on bin name. It will panic is no values have been passed.
func ListAppendWithPolicyContextOp ¶
func ListAppendWithPolicyContextOp(policy *ListPolicy, binName string, ctx []*CDTContext, values ...interface{}) *Operation
ListAppendWithPolicyContextOp creates a list append operation. Server appends values to end of list bin. Server returns list size on bin name. It will panic is no values have been passed.
func ListAppendWithPolicyOp ¶ added in v1.33.0
func ListAppendWithPolicyOp(policy *ListPolicy, binName string, values ...interface{}) *Operation
ListAppendWithPolicyOp creates a list append operation. Server appends values to end of list bin. Server returns list size on bin name. It will panic is no values have been passed.
func ListClearOp ¶ added in v1.9.0
func ListClearOp(binName string, ctx ...*CDTContext) *Operation
ListClearOp creates a list clear operation. Server removes all items in list bin. Server does not return a result by default.
func ListCreateOp ¶
func ListCreateOp(binName string, listOrder ListOrderType, pad bool, ctx ...*CDTContext) *Operation
ListCreateOp creates list create operation. Server creates list at given context level. The context is allowed to be beyond list boundaries only if pad is set to true. In that case, nil list entries will be inserted to satisfy the context position.
func ListGetByIndexOp ¶ added in v1.33.0
func ListGetByIndexOp(binName string, index int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByIndexOp creates list get by index operation. Server selects list item identified by index and returns selected data specified by returnType
func ListGetByIndexRangeCountOp ¶ added in v1.33.0
func ListGetByIndexRangeCountOp(binName string, index, count int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByIndexRangeCountOp creates list get by index range operation. Server selects "count" list items starting at specified index and returns selected data specified by returnType.
func ListGetByIndexRangeOp ¶ added in v1.33.0
func ListGetByIndexRangeOp(binName string, index int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByIndexRangeOp creates list get by index range operation. Server selects list items starting at specified index to the end of list and returns selected data specified by returnType.
func ListGetByRankOp ¶ added in v1.33.0
func ListGetByRankOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByRankOp creates a list get by rank operation. Server selects list item identified by rank and returns selected data specified by returnType.
func ListGetByRankRangeCountOp ¶ added in v1.33.0
func ListGetByRankRangeCountOp(binName string, rank, count int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByRankRangeCountOp creates a list get by rank range operation. Server selects "count" list items starting at specified rank and returns selected data specified by returnType.
func ListGetByRankRangeOp ¶ added in v1.33.0
func ListGetByRankRangeOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByRankRangeOp creates a list get by rank range operation. Server selects list items starting at specified rank to the last ranked item and returns selected data specified by returnType.
func ListGetByValueListOp ¶ added in v1.33.0
func ListGetByValueListOp(binName string, values []interface{}, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByValueListOp creates list get by value list operation. Server selects list items identified by values and returns selected data specified by returnType.
func ListGetByValueOp ¶ added in v1.33.0
func ListGetByValueOp(binName string, value interface{}, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByValueOp creates a list get by value operation. Server selects list items identified by value and returns selected data specified by returnType.
func ListGetByValueRangeOp ¶ added in v1.33.0
func ListGetByValueRangeOp(binName string, beginValue, endValue interface{}, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByValueRangeOp creates a list get by value range operation. Server selects list items identified by value range (valueBegin inclusive, valueEnd exclusive) If valueBegin is null, the range is less than valueEnd. If valueEnd is null, the range is greater than equal to valueBegin. Server returns selected data specified by returnType.
func ListGetByValueRelativeRankRangeCountOp ¶ added in v1.37.0
func ListGetByValueRelativeRankRangeCountOp(binName string, value interface{}, rank, count int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByValueRelativeRankRangeCountOp creates a list get by value relative to rank range operation. Server selects list items nearest to value and greater by relative rank with a count limit. Server returns selected data specified by returnType.
Examples for ordered list [0,4,5,9,11,15]:
(value,rank,count) = [selected items] (5,0,2) = [5,9] (5,1,1) = [9] (5,-1,2) = [4,5] (3,0,1) = [4] (3,3,7) = [11,15] (3,-3,2) = []
func ListGetByValueRelativeRankRangeOp ¶ added in v1.37.0
func ListGetByValueRelativeRankRangeOp(binName string, value interface{}, rank int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListGetByValueRelativeRankRangeOp creates a list get by value relative to rank range operation. Server selects list items nearest to value and greater by relative rank. Server returns selected data specified by returnType.
Examples for ordered list [0,4,5,9,11,15]:
(value,rank) = [selected items] (5,0) = [5,9,11,15] (5,1) = [9,11,15] (5,-1) = [4,5,9,11,15] (3,0) = [4,5,9,11,15] (3,3) = [11,15] (3,-3) = [0,4,5,9,11,15]
func ListGetOp ¶ added in v1.9.0
func ListGetOp(binName string, index int, ctx ...*CDTContext) *Operation
ListGetOp creates a list get operation. Server returns item at specified index in list bin.
func ListGetRangeFromOp ¶ added in v1.11.0
func ListGetRangeFromOp(binName string, index int, ctx ...*CDTContext) *Operation
ListGetRangeFromOp creates a list get range operation. Server returns items starting at specified index to the end of list.
func ListGetRangeOp ¶ added in v1.9.0
func ListGetRangeOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
ListGetRangeOp creates a list get range operation. Server returns "count" items starting at specified index in list bin.
func ListIncrementByOneOp ¶ added in v1.33.0
func ListIncrementByOneOp(binName string, index int, ctx ...*CDTContext) *Operation
ListIncrementOp creates list increment operation with policy. Server increments list[index] by 1. Server returns list[index] after incrementing.
func ListIncrementByOneWithPolicyOp ¶ added in v1.33.0
func ListIncrementByOneWithPolicyOp(policy *ListPolicy, binName string, index int, ctx ...*CDTContext) *Operation
ListIncrementByOneWithPolicyOp creates list increment operation with policy. Server increments list[index] by 1. Server returns list[index] after incrementing.
func ListIncrementOp ¶ added in v1.29.0
func ListIncrementOp(binName string, index int, value interface{}, ctx ...*CDTContext) *Operation
ListIncrementOp creates a list increment operation. Server increments list[index] by value. Value should be integer(IntegerValue, LongValue) or float(FloatValue). Server returns list[index] after incrementing.
func ListIncrementWithPolicyOp ¶ added in v1.33.0
func ListIncrementWithPolicyOp(policy *ListPolicy, binName string, index int, value interface{}, ctx ...*CDTContext) *Operation
ListInsertWithPolicyOp creates a list insert operation. Server inserts value to specified index of list bin. Server returns list size on bin name. It will panic is no values have been passed.
func ListInsertOp ¶ added in v1.9.0
ListInsertOp creates a list insert operation. Server inserts value to specified index of list bin. Server returns list size on bin name. It will panic is no values have been passed.
func ListInsertWithPolicyContextOp ¶
func ListInsertWithPolicyContextOp(policy *ListPolicy, binName string, index int, ctx []*CDTContext, values ...interface{}) *Operation
ListInsertWithPolicyContextOp creates a list insert operation. Server inserts value to specified index of list bin. Server returns list size on bin name. It will panic is no values have been passed.
func ListInsertWithPolicyOp ¶ added in v1.33.0
func ListInsertWithPolicyOp(policy *ListPolicy, binName string, index int, values ...interface{}) *Operation
ListInsertWithPolicyOp creates a list insert operation. Server inserts value to specified index of list bin. Server returns list size on bin name. It will panic is no values have been passed.
func ListPopOp ¶ added in v1.9.0
func ListPopOp(binName string, index int, ctx ...*CDTContext) *Operation
ListPopOp creates list pop operation. Server returns item at specified index and removes item from list bin.
func ListPopRangeFromOp ¶ added in v1.11.0
func ListPopRangeFromOp(binName string, index int, ctx ...*CDTContext) *Operation
ListPopRangeFromOp creates a list pop range operation. Server returns items starting at specified index to the end of list and removes items from list bin.
func ListPopRangeOp ¶ added in v1.9.0
func ListPopRangeOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
ListPopRangeOp creates a list pop range operation. Server returns items starting at specified index and removes items from list bin.
func ListRemoveByIndexOp ¶ added in v1.33.0
func ListRemoveByIndexOp(binName string, index int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByIndexOp creates a list remove operation. Server removes list item identified by index and returns removed data specified by returnType.
func ListRemoveByIndexRangeCountOp ¶ added in v1.33.0
func ListRemoveByIndexRangeCountOp(binName string, index, count int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByIndexRangeCountOp creates a list remove operation. Server removes "count" list items starting at specified index and returns removed data specified by returnType.
func ListRemoveByIndexRangeOp ¶ added in v1.33.0
func ListRemoveByIndexRangeOp(binName string, index, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByIndexRangeOp creates a list remove operation. Server removes list items starting at specified index to the end of list and returns removed data specified by returnType.
func ListRemoveByRankOp ¶ added in v1.33.0
func ListRemoveByRankOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByRankOp creates a list remove operation. Server removes list item identified by rank and returns removed data specified by returnType.
func ListRemoveByRankRangeCountOp ¶ added in v1.33.0
func ListRemoveByRankRangeCountOp(binName string, rank int, count int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByRankRangeCountOp creates a list remove operation. Server removes "count" list items starting at specified rank and returns removed data specified by returnType.
func ListRemoveByRankRangeOp ¶ added in v1.33.0
func ListRemoveByRankRangeOp(binName string, rank int, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByRankRangeOp creates a list remove operation. Server removes list items starting at specified rank to the last ranked item and returns removed data specified by returnType.
func ListRemoveByValueListOp ¶ added in v1.33.0
func ListRemoveByValueListOp(binName string, values []interface{}, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByValueListOp creates list remove by value operation. Server removes list items identified by value and returns removed data specified by returnType.
func ListRemoveByValueOp ¶ added in v1.33.0
func ListRemoveByValueOp(binName string, value interface{}, returnType ListReturnType, ctx ...*CDTContext) *Operation
ListRemoveByValueOp creates list remove by value operation. Server removes the item identified by value and returns removed data specified by returnType.
func ListRemoveByValueRangeOp ¶ added in v1.33.0
func ListRemoveByValueRangeOp(binName string, returnType ListReturnType, valueBegin, valueEnd interface{}, ctx ...*CDTContext) *Operation
ListRemoveByValueRangeOp creates a list remove operation. Server removes list items identified by value range (valueBegin inclusive, valueEnd exclusive). If valueBegin is nil, the range is less than valueEnd. If valueEnd is nil, the range is greater than equal to valueBegin. Server returns removed data specified by returnType
func ListRemoveByValueRelativeRankRangeCountOp ¶ added in v1.37.0
func ListRemoveByValueRelativeRankRangeCountOp(binName string, returnType ListReturnType, value interface{}, rank, count int, ctx ...*CDTContext) *Operation
ListRemoveByValueRelativeRankRangeCountOp creates a list remove by value relative to rank range operation. Server removes list items nearest to value and greater by relative rank with a count limit. Server returns removed data specified by returnType. Examples for ordered list [0,4,5,9,11,15]:
(value,rank,count) = [removed items] (5,0,2) = [5,9] (5,1,1) = [9] (5,-1,2) = [4,5] (3,0,1) = [4] (3,3,7) = [11,15] (3,-3,2) = []
func ListRemoveByValueRelativeRankRangeOp ¶ added in v1.37.0
func ListRemoveByValueRelativeRankRangeOp(binName string, returnType ListReturnType, value interface{}, rank int, ctx ...*CDTContext) *Operation
ListRemoveByValueRelativeRankRangeOp creates a list remove by value relative to rank range operation. Server removes list items nearest to value and greater by relative rank. Server returns removed data specified by returnType.
Examples for ordered list [0,4,5,9,11,15]:
(value,rank) = [removed items] (5,0) = [5,9,11,15] (5,1) = [9,11,15] (5,-1) = [4,5,9,11,15] (3,0) = [4,5,9,11,15] (3,3) = [11,15] (3,-3) = [0,4,5,9,11,15]
func ListRemoveOp ¶ added in v1.9.0
func ListRemoveOp(binName string, index int, ctx ...*CDTContext) *Operation
ListRemoveOp creates a list remove operation. Server removes item at specified index from list bin. Server returns number of items removed.
func ListRemoveRangeFromOp ¶ added in v1.11.0
func ListRemoveRangeFromOp(binName string, index int, ctx ...*CDTContext) *Operation
ListRemoveRangeFromOp creates a list remove range operation. Server removes all items starting at specified index to the end of list. Server returns number of items removed.
func ListRemoveRangeOp ¶ added in v1.9.0
func ListRemoveRangeOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
ListRemoveRangeOp creates a list remove range operation. Server removes "count" items starting at specified index from list bin. Server returns number of items removed.
func ListSetOp ¶ added in v1.9.0
func ListSetOp(binName string, index int, value interface{}, ctx ...*CDTContext) *Operation
ListSetOp creates a list set operation. Server sets item value at specified index in list bin. Server does not return a result by default.
func ListSetOrderOp ¶ added in v1.33.0
func ListSetOrderOp(binName string, listOrder ListOrderType, ctx ...*CDTContext) *Operation
ListSetOrderOp creates a set list order operation. Server sets list order. Server returns null.
func ListSizeOp ¶ added in v1.9.0
func ListSizeOp(binName string, ctx ...*CDTContext) *Operation
ListSizeOp creates a list size operation. Server returns size of list on bin name.
func ListSortOp ¶ added in v1.33.0
func ListSortOp(binName string, sortFlags int, ctx ...*CDTContext) *Operation
ListSortOp creates list sort operation. Server sorts list according to sortFlags. Server does not return a result by default.
func ListTrimOp ¶ added in v1.9.0
func ListTrimOp(binName string, index int, count int, ctx ...*CDTContext) *Operation
ListTrimOp creates a list trim operation. Server removes items in list bin that do not fall into range specified by index and count range. If the range is out of bounds, then all items will be removed. Server returns number of elemts that were removed.
func MapClearOp ¶ added in v1.16.0
func MapClearOp(binName string, ctx ...*CDTContext) *Operation
MapClearOp creates map clear operation. Server removes all items in map. Server returns null.
func MapCreateOp ¶
func MapCreateOp(binName string, order mapOrderType, ctx []*CDTContext) *Operation
MapCreateOp creates a map create operation. Server creates map at given context level.
func MapDecrementOp ¶ added in v1.16.0
func MapDecrementOp(policy *MapPolicy, binName string, key interface{}, decr interface{}, ctx ...*CDTContext) *Operation
MapDecrementOp creates map decrement operation. Server decrements values by decr for all items identified by key and returns final result. Valid only for numbers.
The required map policy dictates the type of map to create when it does not exist. The map policy also specifies the mode used when writing items to the map.
func MapGetByIndexOp ¶ added in v1.16.0
func MapGetByIndexOp(binName string, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByIndexOp creates map get by index operation. Server selects map item identified by index and returns selected data specified by returnType.
func MapGetByIndexRangeCountOp ¶ added in v1.16.0
func MapGetByIndexRangeCountOp(binName string, index int, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByIndexRangeCountOp creates map get by index range operation. Server selects "count" map items starting at specified index and returns selected data specified by returnType.
func MapGetByIndexRangeOp ¶ added in v1.16.0
func MapGetByIndexRangeOp(binName string, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByIndexRangeOp creates map get by index range operation. Server selects map items starting at specified index to the end of map and returns selected data specified by returnType.
func MapGetByKeyListOp ¶ added in v1.33.0
func MapGetByKeyListOp(binName string, keys []interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByKeyListOp creates a map get by key list operation. Server selects map items identified by keys and returns selected data specified by returnType.
func MapGetByKeyOp ¶ added in v1.16.0
func MapGetByKeyOp(binName string, key interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByKeyOp creates map get by key operation. Server selects map item identified by key and returns selected data specified by returnType.
func MapGetByKeyRangeOp ¶ added in v1.16.0
func MapGetByKeyRangeOp(binName string, keyBegin interface{}, keyEnd interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByKeyRangeOp creates map get by key range operation. Server selects map items identified by key range (keyBegin inclusive, keyEnd exclusive). If keyBegin is null, the range is less than keyEnd. If keyEnd is null, the range is greater than equal to keyBegin.
Server returns selected data specified by returnType.
func MapGetByKeyRelativeIndexRangeCountOp ¶ added in v1.37.0
func MapGetByKeyRelativeIndexRangeCountOp(binName string, key interface{}, index, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByKeyRelativeIndexRangeCountOp creates a map get by key relative to index range operation. Server selects map items nearest to key and greater by index with a count limit. Server returns selected data specified by returnType (See {@link MapReturnType}). <p> Examples for ordered map [{0=17},{4=2},{5=15},{9=10}]: <ul> <li>(value,index,count) = [selected items]</li> <li>(5,0,1) = [{5=15}]</li> <li>(5,1,2) = [{9=10}]</li> <li>(5,-1,1) = [{4=2}]</li> <li>(3,2,1) = [{9=10}]</li> <li>(3,-2,2) = [{0=17}]</li>
func MapGetByKeyRelativeIndexRangeOp ¶ added in v1.37.0
func MapGetByKeyRelativeIndexRangeOp(binName string, key interface{}, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByKeyRelativeIndexRangeOp creates a map get by key relative to index range operation. Server selects map items nearest to key and greater by index. Server returns selected data specified by returnType.
Examples for ordered map [{0=17},{4=2},{5=15},{9=10}]:
(value,index) = [selected items] (5,0) = [{5=15},{9=10}] (5,1) = [{9=10}] (5,-1) = [{4=2},{5=15},{9=10}] (3,2) = [{9=10}] (3,-2) = [{0=17},{4=2},{5=15},{9=10}]
func MapGetByRankOp ¶ added in v1.16.0
func MapGetByRankOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByRankOp creates map get by rank operation. Server selects map item identified by rank and returns selected data specified by returnType.
func MapGetByRankRangeCountOp ¶ added in v1.16.0
func MapGetByRankRangeCountOp(binName string, rank int, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByRankRangeCountOp creates map get by rank range operation. Server selects "count" map items starting at specified rank and returns selected data specified by returnType.
func MapGetByRankRangeOp ¶ added in v1.16.0
func MapGetByRankRangeOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByRankRangeOp creates map get by rank range operation. Server selects map items starting at specified rank to the last ranked item and returns selected data specified by returnType.
func MapGetByValueListOp ¶ added in v1.33.0
func MapGetByValueListOp(binName string, values []interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
func MapGetByValueOp ¶ added in v1.16.0
func MapGetByValueOp(binName string, value interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByValueOp creates map get by value operation. Server selects map items identified by value and returns selected data specified by returnType.
func MapGetByValueRangeOp ¶ added in v1.16.0
func MapGetByValueRangeOp(binName string, valueBegin interface{}, valueEnd interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByValueRangeOp creates map get by value range operation. Server selects map items identified by value range (valueBegin inclusive, valueEnd exclusive) If valueBegin is null, the range is less than valueEnd. If valueEnd is null, the range is greater than equal to valueBegin.
Server returns selected data specified by returnType.
func MapGetByValueRelativeRankRangeCountOp ¶ added in v1.37.0
func MapGetByValueRelativeRankRangeCountOp(binName string, value interface{}, rank, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByValueRelativeRankRangeCountOp creates a map get by value relative to rank range operation. Server selects map items nearest to value and greater by relative rank with a count limit. Server returns selected data specified by returnType.
Examples for map [{4=2},{9=10},{5=15},{0=17}]:
(value,rank,count) = [selected items] (11,1,1) = [{0=17}] (11,-1,1) = [{9=10}]
func MapGetByValueRelativeRankRangeOp ¶ added in v1.37.0
func MapGetByValueRelativeRankRangeOp(binName string, value interface{}, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapGetByValueRelativeRankRangeOp creates a map get by value relative to rank range operation. Server selects map items nearest to value and greater by relative rank. Server returns selected data specified by returnType.
Examples for map [{4=2},{9=10},{5=15},{0=17}]:
(value,rank) = [selected items] (11,1) = [{0=17}] (11,-1) = [{9=10},{5=15},{0=17}]
func MapIncrementOp ¶ added in v1.16.0
func MapIncrementOp(policy *MapPolicy, binName string, key interface{}, incr interface{}, ctx ...*CDTContext) *Operation
MapIncrementOp creates map increment operation. Server increments values by incr for all items identified by key and returns final result. Valid only for numbers.
The required map policy dictates the type of map to create when it does not exist. The map policy also specifies the mode used when writing items to the map.
func MapPutItemsOp ¶ added in v1.16.0
func MapPutItemsOp(policy *MapPolicy, binName string, amap map[interface{}]interface{}, ctx ...*CDTContext) *Operation
MapPutItemsOp creates map put items operation Server writes each map item to map bin and returns map size.
The required map policy dictates the type of map to create when it does not exist. The map policy also specifies the mode used when writing items to the map.
func MapPutOp ¶ added in v1.16.0
func MapPutOp(policy *MapPolicy, binName string, key interface{}, value interface{}, ctx ...*CDTContext) *Operation
MapPutOp creates map put operation. Server writes key/value item to map bin and returns map size.
The required map policy dictates the type of map to create when it does not exist. The map policy also specifies the mode used when writing items to the map.
func MapRemoveByIndexOp ¶ added in v1.16.0
func MapRemoveByIndexOp(binName string, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByIndexOp creates map remove operation. Server removes map item identified by index and returns removed data specified by returnType.
func MapRemoveByIndexRangeCountOp ¶ added in v1.16.0
func MapRemoveByIndexRangeCountOp(binName string, index int, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByIndexRangeCountOp creates map remove operation. Server removes "count" map items starting at specified index and returns removed data specified by returnType.
func MapRemoveByIndexRangeOp ¶ added in v1.16.0
func MapRemoveByIndexRangeOp(binName string, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByIndexRangeOp creates map remove operation. Server removes map items starting at specified index to the end of map and returns removed data specified by returnType.
func MapRemoveByKeyListOp ¶ added in v1.16.0
func MapRemoveByKeyListOp(binName string, keys []interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByKeyListOp creates map remove operation. Server removes map items identified by keys and returns removed data specified by returnType.
func MapRemoveByKeyOp ¶ added in v1.16.0
func MapRemoveByKeyOp(binName string, key interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByKeyOp creates map remove operation. Server removes map item identified by key and returns removed data specified by returnType.
func MapRemoveByKeyRangeOp ¶ added in v1.16.0
func MapRemoveByKeyRangeOp(binName string, keyBegin interface{}, keyEnd interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByKeyRangeOp creates map remove operation. Server removes map items identified by key range (keyBegin inclusive, keyEnd exclusive). If keyBegin is null, the range is less than keyEnd. If keyEnd is null, the range is greater than equal to keyBegin.
Server returns removed data specified by returnType.
func MapRemoveByKeyRelativeIndexRangeCountOp ¶ added in v1.37.0
func MapRemoveByKeyRelativeIndexRangeCountOp(binName string, key interface{}, index, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
Create map remove by key relative to index range operation. Server removes map items nearest to key and greater by index with a count limit. Server returns removed data specified by returnType.
Examples for map [{0=17},{4=2},{5=15},{9=10}]:
(value,index,count) = [removed items] (5,0,1) = [{5=15}] (5,1,2) = [{9=10}] (5,-1,1) = [{4=2}] (3,2,1) = [{9=10}] (3,-2,2) = [{0=17}]
func MapRemoveByKeyRelativeIndexRangeOp ¶ added in v1.37.0
func MapRemoveByKeyRelativeIndexRangeOp(binName string, key interface{}, index int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByKeyRelativeIndexRangeOp creates a map remove by key relative to index range operation. Server removes map items nearest to key and greater by index. Server returns removed data specified by returnType.
Examples for map [{0=17},{4=2},{5=15},{9=10}]:
(value,index) = [removed items] (5,0) = [{5=15},{9=10}] (5,1) = [{9=10}] (5,-1) = [{4=2},{5=15},{9=10}] (3,2) = [{9=10}] (3,-2) = [{0=17},{4=2},{5=15},{9=10}]
func MapRemoveByRankOp ¶ added in v1.16.0
func MapRemoveByRankOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByRankOp creates map remove operation. Server removes map item identified by rank and returns removed data specified by returnType.
func MapRemoveByRankRangeCountOp ¶ added in v1.16.0
func MapRemoveByRankRangeCountOp(binName string, rank int, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByRankRangeCountOp creates map remove operation. Server removes "count" map items starting at specified rank and returns removed data specified by returnType.
func MapRemoveByRankRangeOp ¶ added in v1.16.0
func MapRemoveByRankRangeOp(binName string, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByRankRangeOp creates map remove operation. Server removes map items starting at specified rank to the last ranked item and returns removed data specified by returnType.
func MapRemoveByValueListOp ¶ added in v1.16.0
func MapRemoveByValueListOp(binName string, values []interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByValueListOp creates map remove operation. Server removes map items identified by values and returns removed data specified by returnType.
func MapRemoveByValueOp ¶ added in v1.16.0
func MapRemoveByValueOp(binName string, value interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByValueOp creates map remove operation. Server removes map items identified by value and returns removed data specified by returnType.
func MapRemoveByValueRangeOp ¶ added in v1.16.0
func MapRemoveByValueRangeOp(binName string, valueBegin interface{}, valueEnd interface{}, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByValueRangeOp creates map remove operation. Server removes map items identified by value range (valueBegin inclusive, valueEnd exclusive). If valueBegin is null, the range is less than valueEnd. If valueEnd is null, the range is greater than equal to valueBegin.
Server returns removed data specified by returnType.
func MapRemoveByValueRelativeRankRangeCountOp ¶ added in v1.37.0
func MapRemoveByValueRelativeRankRangeCountOp(binName string, value interface{}, rank, count int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByValueRelativeRankRangeCountOp creates a map remove by value relative to rank range operation. Server removes map items nearest to value and greater by relative rank with a count limit. Server returns removed data specified by returnType (See {@link MapReturnType}).
Examples for map [{4=2},{9=10},{5=15},{0=17}]:
(value,rank,count) = [removed items] (11,1,1) = [{0=17}] (11,-1,1) = [{9=10}]
func MapRemoveByValueRelativeRankRangeOp ¶ added in v1.37.0
func MapRemoveByValueRelativeRankRangeOp(binName string, value interface{}, rank int, returnType mapReturnType, ctx ...*CDTContext) *Operation
MapRemoveByValueRelativeRankRangeOp creates a map remove by value relative to rank range operation. Server removes map items nearest to value and greater by relative rank. Server returns removed data specified by returnType.
Examples for map [{4=2},{9=10},{5=15},{0=17}]:
(value,rank) = [removed items] (11,1) = [{0=17}] (11,-1) = [{9=10},{5=15},{0=17}]
func MapSetPolicyOp ¶ added in v1.16.0
func MapSetPolicyOp(policy *MapPolicy, binName string, ctx ...*CDTContext) *Operation
MapSetPolicyOp creates set map policy operation. Server sets map policy attributes. Server returns null.
The required map policy attributes can be changed after the map is created.
func MapSizeOp ¶ added in v1.16.0
func MapSizeOp(binName string, ctx ...*CDTContext) *Operation
MapSizeOp creates map size operation. Server returns size of map.
type OperationType ¶
type OperationType *struct {
// contains filtered or unexported fields
}
OperationType determines operation type
type Partition ¶
type Partition struct { Namespace string PartitionId int // contains filtered or unexported fields }
Partition encapsulates partition information.
func NewPartition ¶
func NewPartition(partitions *Partitions, key *Key, replica ReplicaPolicy, linearize bool) *Partition
NewPartition returns a partition representation
func PartitionForRead ¶
func PartitionForRead(cluster *Cluster, policy *BasePolicy, key *Key) (*Partition, error)
PartitionForRead returns a partition for read purposes
func PartitionForWrite ¶
func PartitionForWrite(cluster *Cluster, policy *BasePolicy, key *Key) (*Partition, error)
PartitionForWrite returns a partition for write purposes
func (*Partition) GetNodeRead ¶
GetNodeRead returns a node for read operations
func (*Partition) GetNodeWrite ¶
GetNodeWrite returns a node for write operations
func (*Partition) PrepareRetryRead ¶
PrepareRetryRead increases sequence number before read retries
func (*Partition) PrepareRetryWrite ¶
PrepareRetryRead increases sequence number before write retries
type Partitions ¶ added in v1.32.0
type Policy ¶
type Policy interface { // Retrieves BasePolicy GetBasePolicy() *BasePolicy // contains filtered or unexported methods }
Policy Interface
type PredExp ¶ added in v1.29.0
type PredExp interface { String() string // contains filtered or unexported methods }
type Priority ¶
type Priority int
Priority of operations on database server. Currently, this only affects Scan operations.
const ( // DEFAULT determines that the server defines the priority. DEFAULT Priority = iota // LOW determines that the server should run the operation in a background thread. LOW // MEDIUM determines that the server should run the operation at medium priority. MEDIUM // HIGH determines that the server should run the operation at the highest priority. HIGH )
type Privilege ¶ added in v1.24.0
type Privilege struct { // Role Code privilegeCode // Namespace determines namespace scope. Apply permission to this namespace only. // If namespace is zero value, the privilege applies to all namespaces. Namespace string // Set name scope. Apply permission to this set within namespace only. // If set is zero value, the privilege applies to all sets within namespace. SetName string }
Privilege determines user access granularity.
type QueryPolicy ¶
type QueryPolicy struct {
MultiPolicy
}
QueryPolicy encapsulates parameters for policy attributes used in query operations.
func NewQueryPolicy ¶ added in v1.0.1
func NewQueryPolicy() *QueryPolicy
NewQueryPolicy generates a new QueryPolicy instance with default values.
type ReadModeAP ¶
type ReadModeAP int
ReadModeAP is the read policy in AP (availability) mode namespaces. It indicates how duplicates should be consulted in a read operation. Only makes a difference during migrations and only applicable in AP mode.
const ( // ONE indicates that a single node should be involved in the read operation. ReadModeAPOne ReadModeAP = iota // ALL indicates that all duplicates should be consulted in // the read operation. ReadModeAPAll )
type ReadModeSC ¶
type ReadModeSC int
ReadModeSC is the read policy in SC (strong consistency) mode namespaces. Determines SC read consistency options.
const ( // ReadModeSCSession ensures this client will only see an increasing sequence of record versions. // Server only reads from master. This is the default. ReadModeSCSession ReadModeSC = iota // ReadModeSCLinearize ensures ALL clients will only see an increasing sequence of record versions. // Server only reads from master. ReadModeSCLinearize // ReadModeSCAllowReplica indicates that the server may read from master or any full (non-migrating) replica. // Increasing sequence of record versions is not guaranteed. ReadModeSCAllowReplica // partitions. Increasing sequence of record versions is not guaranteed. ReadModeSCAllowUnavailable )
type Record ¶
type Record struct { // Key is the record's key. // Might be empty, or may only consist of digest value. Key *Key // Node from which the Record is originating from. Node *Node // Bins is the map of requested name/value bins. Bins BinMap // Generation shows record modification count. Generation uint32 // Expiration is TTL (Time-To-Live). // Number of seconds until record expires. Expiration uint32 }
Record is the container struct for database records. Records are equivalent to rows.
type RecordExistsAction ¶
type RecordExistsAction int
RecordExistsAction determines how to handle writes when the record already exists.
const ( // UPDATE means: Create or update record. // Merge write command bins with existing bins. UPDATE RecordExistsAction = iota // UPDATE_ONLY means: Update record only. Fail if record does not exist. // Merge write command bins with existing bins. UPDATE_ONLY // REPLACE means: Create or replace record. // Delete existing bins not referenced by write command bins. // Supported by Aerospike 2 server versions >= 2.7.5 and // Aerospike 3 server versions >= 3.1.6 and later. REPLACE // REPLACE_ONLY means: Replace record only. Fail if record does not exist. // Delete existing bins not referenced by write command bins. // Supported by Aerospike 2 server versions >= 2.7.5 and // Aerospike 3 server versions >= 3.1.6 and later. REPLACE_ONLY // CREATE_ONLY means: Create only. Fail if record exists. CREATE_ONLY )
type Recordset ¶ added in v1.0.1
type Recordset struct { // Records is a channel on which the resulting records will be sent back. // NOTE: Do not use Records directly. Range on channel returned by Results() instead. // Will be unexported in the future Records chan *Record // contains filtered or unexported fields }
Recordset encapsulates the result of Scan and Query commands.
func (*Recordset) Close ¶ added in v1.0.1
Close all streams from different nodes. A successful close return nil, subsequent calls to the method will return ErrRecordsetClosed.
func (*Recordset) IsActive ¶ added in v1.0.1
IsActive returns true if the operation hasn't been finished or cancelled.
func (*Recordset) Read ¶ added in v1.14.0
Read reads the next record from the Recordset. If the Recordset has been closed, it returns ErrRecordsetClosed.
func (*Recordset) Results ¶ added in v1.4.0
Results returns a new receive-only channel with the results of the Scan/Query. This is a more idiomatic approach to the iterator pattern in getting the results back from the recordset, and doesn't require the user to write the ugly select in their code. Result contains a Record and an error reference.
Example:
recordset, err := client.ScanAll(nil, namespace, set) handleError(err) for res := range recordset.Results() { if res.Err != nil { // handle error here } else { // process record here fmt.Println(res.Record.Bins) } }
type RegisterTask ¶ added in v1.0.1
type RegisterTask struct {
// contains filtered or unexported fields
}
RegisterTask is used to poll for UDF registration completion.
func NewRegisterTask ¶ added in v1.0.1
func NewRegisterTask(cluster *Cluster, packageName string) *RegisterTask
NewRegisterTask initializes a RegisterTask with fields needed to query server nodes.
func (*RegisterTask) IsDone ¶ added in v1.0.1
func (tskr *RegisterTask) IsDone() (bool, error)
IsDone will query all nodes for task completion status.
func (*RegisterTask) OnComplete ¶ added in v1.0.1
func (tskr *RegisterTask) OnComplete() chan error
OnComplete returns a channel that will be closed as soon as the task is finished. If an error is encountered during operation, an error will be sent on the channel.
type RemoveTask ¶ added in v1.0.1
type RemoveTask struct {
// contains filtered or unexported fields
}
RemoveTask is used to poll for UDF registration completion.
func NewRemoveTask ¶ added in v1.0.1
func NewRemoveTask(cluster *Cluster, packageName string) *RemoveTask
NewRemoveTask initializes a RemoveTask with fields needed to query server nodes.
func (*RemoveTask) IsDone ¶ added in v1.0.1
func (tskr *RemoveTask) IsDone() (bool, error)
IsDone will query all nodes for task completion status.
func (*RemoveTask) OnComplete ¶ added in v1.0.1
func (tskr *RemoveTask) OnComplete() chan error
OnComplete returns a channel that will be closed as soon as the task is finished. If an error is encountered during operation, an error will be sent on the channel.
type ReplicaPolicy ¶ added in v1.17.0
type ReplicaPolicy int
ReplicaPolicy defines type of node partition targeted by read commands.
const ( // MASTER reads from node containing key's master partition. // This is the default behavior. MASTER ReplicaPolicy = iota // MASTER_PROLES Distributes reads across nodes containing key's master and replicated partitions // in round-robin fashion. MASTER_PROLES // Distribute reads across all nodes in cluster in round-robin fashion. // This option is useful when the replication factor equals the number // of nodes in the cluster and the overhead of requesting proles is not desired. RANDOM // SEQUENCE Tries node containing master partition first. // If connection fails, all commands try nodes containing replicated partitions. // If socketTimeout is reached, reads also try nodes containing replicated partitions, // but writes remain on master node. SEQUENCE // PREFER_RACK Tries nodes on the same rack first. // // This option requires ClientPolicy.Rackaware to be enabled // in order to function properly. PREFER_RACK )
func GetReplicaPolicySC ¶
func GetReplicaPolicySC(policy *BasePolicy) ReplicaPolicy
GetReplicaPolicySC returns a ReplicaPolicy based on different variables in SC mode
type ScanPolicy ¶
type ScanPolicy struct { MultiPolicy // ScanPercent determines percent of data to scan. // Valid integer range is 1 to 100. // Default is 100. ScanPercent int //= 100; // ConcurrentNodes determines how to issue scan requests (in parallel or sequentially). ConcurrentNodes bool //= true; }
ScanPolicy encapsulates parameters used in scan operations.
func NewScanPolicy ¶ added in v1.0.1
func NewScanPolicy() *ScanPolicy
NewScanPolicy creates a new ScanPolicy instance with default values.
type Statement ¶ added in v1.0.1
type Statement struct { // Namespace determines query Namespace Namespace string // SetName determines query Set name (Optional) SetName string // IndexName determines query index name (Optional) // If not set, the server will determine the index from the filter's bin name. IndexName string // BinNames detemines bin names (optional) BinNames []string // Filter determines query index filter (Optional). // This filter is applied to the secondary index on query. // Query index filters must reference a bin which has a secondary index defined. Filter *Filter // TaskId determines query task id. (Optional) TaskId uint64 // contains filtered or unexported fields }
Statement encapsulates query statement parameters.
func NewStatement ¶ added in v1.0.1
NewStatement initializes a new Statement instance.
func (*Statement) IsScan ¶ added in v1.0.1
IsScan determines is the Statement is a full namespace/set scan or a selective Query.
func (*Statement) SetAggregateFunction ¶ added in v1.0.1
func (stmt *Statement) SetAggregateFunction(packageName string, functionName string, functionArgs []Value, returnData bool)
SetAggregateFunction sets aggregation function parameters. This function will be called on both the server and client for each selected item.
func (*Statement) SetFilter ¶
SetFilter Sets a filter for the statement. Aerospike Server currently only supports using a single filter per statement/query.
func (*Statement) SetPredExp ¶ added in v1.26.0
SetPredExp sets low-level predicate expressions for the statement in postfix notation. Supported only by Aerospike Server v3.12+. Predicate expression filters are applied on the query results on the server. Predicate expression filters may occur on any bin in the record. To learn how to use this API, consult predexp_test.go file.
Postfix notation is described here: http://wiki.c2.com/?PostfixNotation
Example: (c >= 11 and c <= 20) or (d > 3 and (d < 5)
stmt.SetPredExp(
NewPredExpIntegerValue(11), NewPredExpIntegerBin("c"), NewPredExpIntegerGreaterEq(), NewPredExpIntegerValue(20), NewPredExpIntegerBin("c"), NewPredExpIntegerLessEq(), NewPredExpAnd(2), NewPredExpIntegerValue(3), NewPredExpIntegerBin("d"), NewPredExpIntegerGreater(), NewPredExpIntegerValue(5), NewPredExpIntegerBin("d"), NewPredExpIntegerLess(), NewPredExpAnd(2), NewPredExpOr(2)
);
// Record last update time > 2017-01-15 stmt.SetPredExp(
NewIntegerValue(time.Date(2017, 0, 15, 0, 0, 0, 0, time.UTC).UnixNano()), NewPredExpLastUpdate(), NewPredExpIntegerGreater(),
);
type StringValue ¶
type StringValue string
StringValue encapsulates a string value.
func NewStringValue ¶
func NewStringValue(value string) StringValue
NewStringValue generates a StringValue instance.
func (StringValue) EstimateSize ¶
func (vl StringValue) EstimateSize() (int, error)
func (StringValue) GetObject ¶
func (vl StringValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (StringValue) GetType ¶
func (vl StringValue) GetType() int
GetType returns wire protocol value type.
func (StringValue) String ¶
func (vl StringValue) String() string
String implements Stringer interface.
type Task ¶ added in v1.0.1
type Task interface { IsDone() (bool, error) OnComplete() chan error // contains filtered or unexported methods }
Task interface defines methods for asynchronous tasks.
type UDF ¶ added in v1.0.1
type UDF struct { // Filename of the UDF Filename string // Hash digest of the UDF Hash string // Language of UDF Language Language }
UDF carries information about UDFs on the server
type UserRoles ¶ added in v1.3.0
type UserRoles struct { // User name. User string // Roles is a list of assigned roles. Roles []string }
UserRoles contains information about a user.
type Value ¶
type Value interface { // Calculate number of vl.bytes necessary to serialize the value in the wire protocol. EstimateSize() (int, error) // GetType returns wire protocol value type. GetType() int // GetObject returns original value as an interface{}. GetObject() interface{} // String implements Stringer interface. String() string // contains filtered or unexported methods }
Value interface is used to efficiently serialize objects into the wire protocol.
func NewValue ¶
func NewValue(v interface{}) Value
NewValue generates a new Value object based on the type. If the type is not supported, NewValue will panic. This method is a convenience method, and should not be used when absolute performance is required unless for the reason mentioned below.
If you have custom maps or slices like:
type MyMap map[primitive1]primitive2, eg: map[int]string
or
type MySlice []primitive, eg: []float64
cast them to their primitive type when passing them to this method:
v := NewValue(map[int]string(myVar)) v := NewValue([]float64(myVar))
This way you will avoid hitting reflection. To completely avoid reflection in the library, use the build tag: as_performance while building your program.
type ValueArray ¶
type ValueArray []Value
ValueArray encapsulates an array of Value. Supported by Aerospike 3+ servers only.
func NewValueArray ¶
func NewValueArray(array []Value) *ValueArray
NewValueArray generates a ValueArray instance.
func (ValueArray) EstimateSize ¶
func (va ValueArray) EstimateSize() (int, error)
func (ValueArray) GetObject ¶
func (va ValueArray) GetObject() interface{}
GetObject returns original value as an interface{}.
func (ValueArray) GetType ¶
func (va ValueArray) GetType() int
GetType returns wire protocol value type.
func (ValueArray) String ¶
func (va ValueArray) String() string
String implements Stringer interface.
type WildCardValue ¶ added in v1.37.0
type WildCardValue struct{}
InfinityValue is an empty value.
func NewWildCardValue ¶ added in v1.37.0
func NewWildCardValue() WildCardValue
NewWildCardValue generates a WildCardValue instance.
func (WildCardValue) EstimateSize ¶
func (vl WildCardValue) EstimateSize() (int, error)
func (WildCardValue) GetObject ¶ added in v1.37.0
func (vl WildCardValue) GetObject() interface{}
GetObject returns original value as an interface{}.
func (WildCardValue) GetType ¶ added in v1.37.0
func (vl WildCardValue) GetType() int
GetType returns wire protocol value type.
func (WildCardValue) String ¶ added in v1.37.0
func (vl WildCardValue) String() string
type WritePolicy ¶
type WritePolicy struct { BasePolicy // RecordExistsAction qualifies how to handle writes where the record already exists. RecordExistsAction RecordExistsAction //= RecordExistsAction.UPDATE; // GenerationPolicy qualifies how to handle record writes based on record generation. The default (NONE) // indicates that the generation is not used to restrict writes. GenerationPolicy GenerationPolicy //= GenerationPolicy.NONE; // Desired consistency guarantee when committing a transaction on the server. The default // (COMMIT_ALL) indicates that the server should wait for master and all replica commits to // be successful before returning success to the client. CommitLevel CommitLevel //= COMMIT_ALL // Generation determines expected generation. // Generation is the number of times a record has been // modified (including creation) on the server. // If a write operation is creating a record, the expected generation would be 0. Generation uint32 // Expiration determines record expiration in seconds. Also known as TTL (Time-To-Live). // Seconds record will live before being removed by the server. // Expiration values: // TTLServerDefault (0): Default to namespace configuration variable "default-ttl" on the server. // TTLDontExpire (MaxUint32): Never expire for Aerospike 2 server versions >= 2.7.2 and Aerospike 3+ server // TTLDontUpdate (MaxUint32 - 1): Do not change ttl when record is written. Supported by Aerospike server versions >= 3.10.1 // > 0: Actual expiration in seconds. Expiration uint32 // RespondPerEachOp defines for client.Operate() method, return a result for every operation. // Some list operations do not return results by default (ListClearOp() for example). // This can sometimes make it difficult to determine the desired result offset in the returned // bin's result list. // // Setting RespondPerEachOp to true makes it easier to identify the desired result offset // (result offset equals bin's operate sequence). This only makes sense when multiple list // operations are used in one operate call and some of those operations do not return results // by default. RespondPerEachOp bool // DurableDelete leaves a tombstone for the record if the transaction results in a record deletion. // This prevents deleted records from reappearing after node failures. // Valid for Aerospike Server Enterprise Edition 3.10+ only. DurableDelete bool }
WritePolicy encapsulates parameters for policy attributes used in write operations. This object is passed into methods where database writes can occur.
func NewWritePolicy ¶
func NewWritePolicy(generation, expiration uint32) *WritePolicy
NewWritePolicy initializes a new WritePolicy instance with default parameters.
Source Files ¶
- admin_command.go
- admin_policy.go
- aerospike.go
- auth_mode.go
- batch_command.go
- batch_command_exists.go
- batch_command_get.go
- batch_command_get_reflect.go
- batch_command_reflect.go
- batch_index_command_get.go
- batch_node.go
- batch_policy.go
- batch_read.go
- bin.go
- bit_overflow_action.go
- bit_policy.go
- bit_resize_flags.go
- bit_write_flags.go
- buffered_connection.go
- bytes_buffer.go
- cdt.go
- cdt_bitwise.go
- cdt_context.go
- cdt_list.go
- cdt_map.go
- client.go
- client_appengine_exclusions.go
- client_policy.go
- client_reflect.go
- cluster.go
- command.go
- commit_policy.go
- compat_after_go1.8.go
- connection.go
- connection_heap.go
- delete_command.go
- execute_command.go
- execute_task.go
- exists_command.go
- field_type.go
- filter.go
- generation_policy.go
- generics.go
- hll_operation.go
- hll_policy.go
- hll_write_flags.go
- host.go
- index_collection_type.go
- index_type.go
- info.go
- info_policy.go
- key.go
- key_helper.go
- language.go
- login_command.go
- marshal.go
- multi_command.go
- multi_policy.go
- node.go
- node_error.go
- node_stats.go
- node_validator.go
- operate_command.go
- operation.go
- packer.go
- packer_reflect.go
- partition.go
- partition_parser.go
- partitions.go
- peers.go
- peers_parser.go
- policy.go
- predexp.go
- priority.go
- privilege.go
- query_aggregate_command.go
- query_command.go
- query_objects_command.go
- query_policy.go
- query_record_command.go
- query_validate.go
- read_command.go
- read_command_reflect.go
- read_header_command.go
- read_mode_ap.go
- read_mode_sc.go
- record.go
- record_exists_action.go
- recordset.go
- replica_policy.go
- role.go
- scan_command.go
- scan_objects_command.go
- scan_policy.go
- server_command.go
- single_command.go
- statement.go
- task.go
- task_drop_index.go
- task_index.go
- task_register.go
- task_remove.go
- touch_command.go
- udf.go
- unpacker.go
- user_roles.go
- value.go
- value_helpers.go
- value_reflect.go
- write_command.go
- write_policy.go