Versions in this module Expand all Collapse all v4 v4.7.1 Jul 11, 2023 Changes in this version + const CITRUSLEAF_EPOCH + const MSG_HEADER_SIZE + const MSG_INFO + const MSG_MESSAGE + var ErrConnectionPoolEmpty = NewAerospikeError(NO_AVAILABLE_CONNECTIONS_TO_NODE, ...) + var ErrFilteredOut = NewAerospikeError(FILTERED_OUT) + var ErrKeyNotFound = NewAerospikeError(KEY_NOT_FOUND_ERROR) + var ErrNoBinNamesAlloedInQueryExecute = NewAerospikeError(INVALID_COMMAND, "Statement.BinNames must be empty for QueryExecute") + var ErrNoOperationsSpecified = NewAerospikeError(INVALID_COMMAND, "No operations were passed to QueryExecute") + var ErrPartitionScanQueryNotSupported = NewAerospikeError(PARAMETER_ERROR, ...) + var ErrQueryTerminated = NewAerospikeError(QUERY_TERMINATED) + var ErrRecordsetClosed = NewAerospikeError(RECORDSET_CLOSED) + var ErrScanTerminated = NewAerospikeError(SCAN_TERMINATED) + var ErrServerNotAvailable = NewAerospikeError(SERVER_NOT_AVAILABLE) + var ErrTimeout = NewAerospikeError(TIMEOUT, "command execution timed out on client: See `Policy.Timeout`") + var ErrTooManyConnectionsForNode = NewAerospikeError(NO_AVAILABLE_CONNECTIONS_TO_NODE, ...) + var ErrTooManyOpeningConnections = NewAerospikeError(NO_AVAILABLE_CONNECTIONS_TO_NODE, ...) + var ErrUDFBadResponse = NewAerospikeError(UDF_BAD_RESPONSE, "Invalid UDF return value") + func KeepConnection(err error) bool + func NewAerospikeError(code ResultCode, messages ...string) error + func ResultCodeToString(resultCode ResultCode) string + func TTL(secsFromCitrusLeafEpoc uint32) uint32 + type AerospikeError struct + func (ase *AerospikeError) MarkInDoubt() + func (ase *AerospikeError) SetInDoubt(isRead bool, commandSentCounter int) + func (ase AerospikeError) InDoubt() bool + func (ase AerospikeError) ResultCode() ResultCode + type BufferPool struct + func NewBufferPool(poolSize, initBufferSize, maxBufferSize int) *BufferPool + func (bp *BufferPool) Get() (res []byte) + func (bp *BufferPool) Put(buf []byte) + type Message struct + Data []byte + func NewMessage(mtype messageType, data []byte) *Message + func (msg *Message) Resize(newSize int64) error + func (msg *Message) Serialize() ([]byte, error) + type MessageHeader struct + DataLen [6]byte + Type uint8 + Version uint8 + func (msg *MessageHeader) Length() int64 + type Pool struct + CanReturn func(obj interface{}) bool + Finalize func(obj interface{}) + IsUsable func(obj interface{}, params ...interface{}) bool + New func(params ...interface{}) interface{} + func NewPool(poolSize int) *Pool + func (bp *Pool) Get(params ...interface{}) interface{} + func (bp *Pool) Put(obj interface{}) + type ResultCode int + const AEROSPIKE_ERR_LUA_FILE_NOT_FOUND + const AEROSPIKE_ERR_UDF_NOT_FOUND + const ALWAYS_FORBIDDEN + const BATCH_DISABLED + const BATCH_MAX_REQUESTS_EXCEEDED + const BATCH_QUEUES_FULL + const BIN_EXISTS_ERROR + const BIN_NAME_TOO_LONG + const BIN_NOT_FOUND + const BIN_TYPE_ERROR + const CLUSTER_KEY_MISMATCH + const CLUSTER_NAME_MISMATCH_ERROR + const COMMAND_REJECTED + const DEVICE_OVERLOAD + const ENTERPRISE_ONLY + const EXPIRED_PASSWORD + const EXPIRED_SESSION + const FAIL_ELEMENT_EXISTS + const FAIL_ELEMENT_NOT_FOUND + const FAIL_FORBIDDEN + const FILTERED_OUT + const FORBIDDEN_PASSWORD + const GENERATION_ERROR + const GEO_INVALID_GEOJSON + const ILLEGAL_STATE + const INDEX_FOUND + const INDEX_GENERIC + const INDEX_MAXCOUNT + const INDEX_NAME_MAXLEN + const INDEX_NOTFOUND + const INDEX_NOTREADABLE + const INDEX_OOM + const INVALID_CLUSTER_PARTITION_MAP + const INVALID_COMMAND + const INVALID_CREDENTIAL + const INVALID_FIELD + const INVALID_NAMESPACE + const INVALID_NODE_ERROR + const INVALID_PASSWORD + const INVALID_PRIVILEGE + const INVALID_ROLE + const INVALID_USER + const INVALID_WHITELIST + const KEY_BUSY + const KEY_EXISTS_ERROR + const KEY_MISMATCH + const KEY_NOT_FOUND_ERROR + const LOST_CONFLICT + const MAX_ERROR_RATE + const MAX_RETRIES_EXCEEDED + const NOT_AUTHENTICATED + const NOT_WHITELISTED + const NO_AVAILABLE_CONNECTIONS_TO_NODE + const OK + const OP_NOT_APPLICABLE + const PARAMETER_ERROR + const PARSE_ERROR + const PARTITION_UNAVAILABLE + const QUERY_ABORTED + const QUERY_DUPLICATE + const QUERY_END + const QUERY_GENERIC + const QUERY_NETIO_ERR + const QUERY_QUEUEFULL + const QUERY_TERMINATED + const QUERY_TIMEOUT + const RACK_NOT_DEFINED + const RECORDSET_CLOSED + const RECORD_TOO_BIG + const ROLE_ALREADY_EXISTS + const ROLE_VIOLATION + const SCAN_ABORT + const SCAN_TERMINATED + const SECURITY_NOT_ENABLED + const SECURITY_NOT_SUPPORTED + const SECURITY_SCHEME_NOT_SUPPORTED + const SERIALIZE_ERROR + const SERVER_ERROR + const SERVER_MEM_ERROR + const SERVER_NOT_AVAILABLE + const TIMEOUT + const TYPE_NOT_SUPPORTED + const UDF_BAD_RESPONSE + const UNSUPPORTED_FEATURE + const USER_ALREADY_EXISTS Other modules containing this package github.com/aerospike/aerospike-client-go github.com/aerospike/aerospike-client-go/v5 github.com/aerospike/aerospike-client-go/v6 github.com/aerospike/aerospike-client-go/v7 github.com/aerospike/aerospike-client-go/v8
Go to main page