FetchCounter Class
Command used to fetch a counter value from Riak.
As a convenience, a builder class is provided:
var fetch = new FetchCounter.Builder()
.withBucketType('myBucketType')
.withBucket('myBucket')
.withKey('myKey')
.withCallback(myCallback)
.build();
Constructor
FetchCounter
(
-
options
-
callback
Parameters:
-
options
ObjectThe options to use for this command.
-
bucketType
StringThe bucket type in Riak.
-
bucket
StringThe bucket in Riak.
-
key
StringThe key for the counter you want to fetch.
-
[timeout]
Number optionalSet a timeout in Riak for this operation.
-
[r]
Number optionalThe R value to use for this fetch.
-
[pr]
Number optionalThe PR value to use for this fetch.
-
[notFoundOk]
Boolean optionalIf true a vnode returning notfound for a key increments the R tally.
-
[useBasicQuorum]
Boolean optionalControls whether a read request should return early in some fail cases.
-
-
callback
FunctionThe callback to be executed when the operation completes.
-
err
StringAn error message. Will be null if no error.
-
response
ObjectThe response from Riak.
-
counterValue
NumberThe counter value in Riak. -
isNotFound
BooleanTrue if there was no counter in Riak.
-
-
data
Objectadditional error data. Will be null if no error.
-
Item Index
Methods
constructPbRequest
()
Object
protected
Construct and return the Riak protocol buffer message for this command.
Subclasses must override this method.
Returns:
Object:
a protocol buffer message builder
getCallback
()
Function
private
Fires the user's callback with the arguments passed in.
Returns:
Function:
the user supplied callback
getExpectedResponseCode
()
Number
private
Returns the expected response code for this command.
Returns:
Number:
the expected response code for this command.
getPbReqBuilder
()
Object
private
Returns and instance of the protocol buffer message builder for this command.
This is determined via the pbRequestName passed to the constructor.
Returns:
Object:
the builder for the protocol buffer message to be sent for this command
getRiakMessage
()
Object
private
Returns the encoded protobuf and message header.
Returns:
Object:
object containing the header and encoded protobuf
onError
(
protected
-
msg
-
data
Called by RiakNode if an error occurs executing the command and all retries are exhausted.
Parameters:
-
msg
Stringan error message -
data
Objectadditional error data
onRiakError
(
protected
-
rpbErrorResp
Called by RiakNode when a RpbErrorResp is received and all retries are exhausted.
Commands may override this method.
Parameters:
-
rpbErrorResp
Objectthe RpbErrorResp protocol buffer
onSuccess
(
Boolean
protected
-
pbResponseMessage
Called by RiakNode when a response is received.
Subclasses must override this method.
Parameters:
-
pbResponseMessage
Objectthe protocol buffer received from riak
Returns:
Boolean:
true if not streaming or the last response has been received, false otherwise.