Documentation ¶
Index ¶
- Constants
- func KeepConnection(resultCode int) bool
- func NewAerospikeError(code ResultCode, messages ...string) error
- func ResultCodeToString(resultCode ResultCode) string
- func TTL(secsFromCitrusLeafEpoc int) int
- type AerospikeError
- type BufferPool
- type Message
- type MessageHeader
- type Pool
- type ResultCode
Constants ¶
const ( MSG_HEADER_SIZE = 8 //sizeof(MessageHeader) MSG_INFO messageType = 1 MSG_MESSAGE = 3 )
const (
// citrusleaf epoc: Jan 01 2010 00:00:00 GMT
CITRUSLEAF_EPOCH = 1262304000
)
Variables ¶
This section is empty.
Functions ¶
func KeepConnection ¶
Should connection be put back into pool.
func NewAerospikeError ¶
func NewAerospikeError(code ResultCode, messages ...string) error
New AerospikeError generates a new AerospikeError instance. If no message is provided, the result code will be translated into the default error message automatically.
func ResultCodeToString ¶
func ResultCodeToString(resultCode ResultCode) string
Return result code as a string.
Types ¶
type AerospikeError ¶
type AerospikeError struct {
// contains filtered or unexported fields
}
AerospikeError implements error interface for aerospike specific errors. All errors returning from the library are of this type. Errors resulting from Go's stdlib are not translated to this type, unless they are a net.Timeout error.
func (AerospikeError) ResultCode ¶
func (ase AerospikeError) ResultCode() ResultCode
ResultCode returns the ResultCode from AerospikeError object.
type BufferPool ¶ added in v1.0.1
type BufferPool struct {
// contains filtered or unexported fields
}
BufferPool implements a specialized buffer pool. Pool size will be limited, and each buffer size will be constrained to the init and max buffer sizes.
func NewBufferPool ¶ added in v1.0.1
func NewBufferPool(poolSize, initBufferSize, maxBufferSize int) *BufferPool
NewBufferPool creates a new buffer pool. New buffers will be created with size and capacity of initBufferSize. If cap(buffer) is larger than maxBufferSize when it is put back in the buffer, it will be thrown away. This will prevent unwanted memory bloat and set a deterministic maximum-size for the pool which will not be exceeded.
func (*BufferPool) Get ¶ added in v1.0.1
func (bp *BufferPool) Get() (res []byte)
Get returns a buffer from the pool. If pool is empty, a new buffer of size initBufSize will be created and returned.
func (*BufferPool) Put ¶ added in v1.0.1
func (bp *BufferPool) Put(buf []byte)
Put will put the buffer back in the pool, unless cap(buf) is bigger than initBufSize, in which case it will be thrown away
type Message ¶
type Message struct { MessageHeader Data []byte }
func NewMessage ¶
NewMessage generates a new Message instance.
type MessageHeader ¶
func (*MessageHeader) Length ¶
func (msg *MessageHeader) Length() int64
Length returns the length of the message
type Pool ¶ added in v1.0.1
type Pool struct { New func() interface{} // contains filtered or unexported fields }
Pool implements a general purpose fixed-size pool.
type ResultCode ¶
type ResultCode int
ResultCode signifies the database operation error codes. The positive numbers align with the server side file proto.h.
const ( // End of Recordset in Query or Scan. END_OF_RECORDSET ResultCode = -8 // Asynchronous max concurrent database commands have been exceeded and therefore rejected. TYPE_NOT_SUPPORTED ResultCode = -7 // Asynchronous max concurrent database commands have been exceeded and therefore rejected. COMMAND_REJECTED ResultCode = -6 // Query was terminated by user. QUERY_TERMINATED ResultCode = -5 // Scan was terminated by user. SCAN_TERMINATED ResultCode = -4 // Chosen node is not currently active. INVALID_NODE_ERROR ResultCode = -3 // Client parse error. PARSE_ERROR ResultCode = -2 // Client serialization error. SERIALIZE_ERROR ResultCode = -1 // Operation was successful. OK ResultCode = 0 // Unknown server failure. SERVER_ERROR ResultCode = 1 // On retrieving, touching or replacing a record that doesn't exist. KEY_NOT_FOUND_ERROR ResultCode = 2 // On modifying a record with unexpected generation. GENERATION_ERROR ResultCode = 3 // Bad parameter(s) were passed in database operation call. PARAMETER_ERROR ResultCode = 4 // On create-only (write unique) operations on a record that already // exists. KEY_EXISTS_ERROR ResultCode = 5 // On create-only (write unique) operations on a bin that already // exists. BIN_EXISTS_ERROR ResultCode = 6 // Expected cluster ID was not received. CLUSTER_KEY_MISMATCH ResultCode = 7 // Server has run out of memory. SERVER_MEM_ERROR ResultCode = 8 // Client or server has timed out. TIMEOUT ResultCode = 9 // XDS product is not available. NO_XDS ResultCode = 10 // Server is not accepting requests. SERVER_NOT_AVAILABLE ResultCode = 11 // Operation is not supported with configured bin type (single-bin or // multi-bin). BIN_TYPE_ERROR ResultCode = 12 // Record size exceeds limit. RECORD_TOO_BIG ResultCode = 13 // Too many concurrent operations on the same record. KEY_BUSY ResultCode = 14 // Scan aborted by server. SCAN_ABORT ResultCode = 15 // Unsupported Server Feature (e.g. Scan + UDF) UNSUPPORTED_FEATURE ResultCode = 16 // Specified bin name does not exist in record. BIN_NOT_FOUND ResultCode = 17 // Specified bin name does not exist in record. DEVICE_OVERLOAD ResultCode = 18 // Key type mismatch. KEY_MISMATCH ResultCode = 19 // Invalid namespace. INVALID_NAMESPACE ResultCode = 20 // Bin name length greater than 14 characters. BIN_NAME_TOO_LONG ResultCode = 21 // There are no more records left for query. QUERY_END ResultCode = 50 SECURITY_NOT_SUPPORTED ResultCode = 51 SECURITY_NOT_ENABLED ResultCode = 52 SECURITY_SCHEME_NOT_SUPPORTED ResultCode = 53 // Administration command is invalid. INVALID_COMMAND ResultCode = 54 // Administration field is invalid. INVALID_FIELD ResultCode = 55 ILLEGAL_STATE ResultCode = 56 // User name is invalid. INVALID_USER ResultCode = 60 // User was previously created. USER_ALREADY_EXISTS ResultCode = 61 // Password is invalid. INVALID_PASSWORD ResultCode = 62 // Security credential is invalid. INVALID_CREDENTIAL ResultCode = 63 // Role name is invalid. INVALID_ROLE ResultCode = 70 INVALID_PRIVILEGE ResultCode = 71 // User must be authentication before performing database operations. NOT_AUTHENTICATED ResultCode = 80 // User does not posses the required role to perform the database operation. ROLE_VIOLATION ResultCode = 81 // A user defined function returned an error code. UDF_BAD_RESPONSE ResultCode = 100 // The requested item in a large collection was not found. LARGE_ITEM_NOT_FOUND ResultCode = 125 // Secondary index already exists. INDEX_FOUND ResultCode = 200 // Requested secondary index does not exist. INDEX_NOTFOUND ResultCode = 201 // Secondary index memory space exceeded. INDEX_OOM ResultCode = 202 // Secondary index not available. INDEX_NOTREADABLE ResultCode = 203 // Generic secondary index error. INDEX_GENERIC ResultCode = 204 // Index name maximum length exceeded. INDEX_NAME_MAXLEN ResultCode = 205 // Maximum number of indicies exceeded. INDEX_MAXCOUNT ResultCode = 206 // Secondary index query aborted. QUERY_ABORTED ResultCode = 210 // Secondary index queue full. QUERY_QUEUEFULL ResultCode = 211 // Secondary index query timed out on server. QUERY_TIMEOUT ResultCode = 212 // Generic query error. QUERY_GENERIC ResultCode = 213 )