at_commons library

Classes

AtBuffer<T>
Class holder for message of different data types(int, String etc.,)
AtCompactionConfig
AtKey
AtValue
BatchRequest
BatchResponse
ByteBuffer
Metadata
Response
StringBuffer
UpdateParams
VerbSyntax
VerbUtil

Extensions

AtMessageExtension

Constants

AT_CRAM_SECRET → const String
'privatekey:at_secret'
AT_CRAM_SECRET_DELETED → const String
'privatekey:at_secret_deleted'
AT_DIGEST → const String
'digest'
AT_ENCRYPTION_PRIVATE_KEY → const String
'privatekey:privatekey'
AT_ENCRYPTION_PUBLIC_KEY → const String
'public:publickey'
AT_ENCRYPTION_SELF_KEY → const String
'privatekey:self_encryption_key'
AT_ENCRYPTION_SHARED_KEY → const String
'shared_key'
AT_FROM_COMMIT_SEQUENCE → const String
'from_commit_seq'
AT_KEY → const String
'atKey'
AT_OPERATION → const String
'operation'
AT_PKAM_PRIVATE_KEY → const String
'privatekey:at_pkam_privatekey'
AT_PKAM_PUBLIC_KEY → const String
'privatekey:at_pkam_publickey'
AT_PKAM_SIGNATURE → const String
'signature'
AT_REGEX → const String
'regex'
AT_SIGN → const String
'atSign'
AT_SIGNING_KEYPAIR_GENERATED → const String
'privatekey:signing_keypair_generated'
AT_SIGNING_PRIVATE_KEY → const String
'signing_privatekey'
AT_SIGNING_PUBLIC_KEY → const String
'public:signing_publickey'
AT_STAT_ID → const String
'statId'
AT_TTB → const String
'ttb'
AT_TTL → const String
'ttl'
AT_TTR → const String
'ttr'
AT_VALUE → const String
'value'
AT_VALUE_REFERENCE → const String
'atsign://'
CACHED → const String
'cached'
CCD → const String
'ccd'
CREATED_AT → const String
'createdAt'
EPOCH_MILLIS → const String
'epochMillis'
error_codes → const Map
const {'AtServerException' : 'AT0001', 'DataStoreException' : 'AT0002', 'InvalidSyntaxException' : 'AT0003', 'SocketException' : 'AT0004'…
error_description → const Map
const {'AT0001' : 'Server exception', 'AT0002' : 'DataStore exception', 'AT0003' : 'Invalid syntax', 'AT0004' : 'Socket error', 'AT0…
FIRST_BYTE → const String
'#'
FOR_AT_SIGN → const String
'forAtSign'
FROM → const String
'from'
FROM_AT_SIGN → const String
'fromAtSign'
ID → const String
'id'
IS_BINARY → const String
'isBinary'
IS_ENCRYPTED → const String
'isEncrypted'
IS_PUBLIC → const String
'isPublic'
KEY → const String
'key'
LATEST_N → const String
'latestN'
MESSAGE_TYPE → const String
'messageType'
NOTIFICATION → const String
'notification'
NOTIFIER → const String
'notifier'
OPERATION → const String
'operation'
PRIORITY → const String
'priority'
PUBLIC_DATA_SIGNATURE → const String
'dataSignature'
REFRESH_AT → const String
'refreshAt'
STRATEGY → const String
'strategy'
SYSTEM → const String
'SYSTEM'
TO → const String
'to'
TO_AT_SIGN → const String
'toAtSign'
UPDATE_ALL → const String
'all'
UPDATE_JSON → const String
'update:json'
UPDATE_META → const String
'meta'
UPDATED_AT → const String
'updatedAt'
VALUE → const String
'value'

Functions

getMessageType(MessageTypeEnum messageTypeEnum) String
getOperationName(OperationEnum d) String
getPriority(PriorityEnum priorityEnum) String
getStrategy(StrategyEnum strategyEnum) String

Enums

AtMessage
MessageTypeEnum
OperationEnum
PriorityEnum
StrategyEnum

Exceptions / Errors

AtBufferOverFlowException
AtConnectException
Parent exception for any connection specific exception
AtException
AtIOException
Raised when there is any issue related to socket operations e.g read/write
AtServerException
Raised for critical issue during secondary or root server startup operation
BlockedConnectionException
Thrown if the atsign is in blocklist.
BufferOverFlowException
ConnectionInvalidException
Thrown when trying to perform a read/write on a connection which is invalid
HandShakeException
Thrown when a handshake to another secondary server fails
IllegalArgumentException
Throws when user inputs invalid arguments
InboundConnectionLimitException
Thrown when current server's inbound connection limit is reached
InternalServerError
Thrown for any unhandled server error
InternalServerException
Thrown for any unhandled server exception
InvalidAtSignException
Thrown if the atSign is invalid
InvalidSyntaxException
Thrown for invalid syntax before executing a verb.
KeyNotFoundException
Throws when users tries to perform an invalid operation.
LookupException
Thrown when lookup fails after handshake
OutBoundConnectionInvalidException
Thrown when trying to perform a read/write on an outbound connection which is invalid
OutboundConnectionLimitException
Thrown when current server's outbound connection limit is reached
SecondaryConnectException
Thrown when a user's secondary url cannot be reached or unavailable
SecondaryNotFoundException
Thrown when a user's secondary server is not found
UnAuthenticatedException
Thrown when trying to perform a verb execution which requires authentication
UnAuthorizedException
Thrown when trying to execute a command with authorization e.g Performing a lookup without a proper handshake to another secondary