PBC Store Object
Stores an object under the specified location, as determined by the
intended key, bucket, and bucket type. A bucket must always be specified (via
bucket), whereas key (key) and bucket type (type) are optional. If
no key is specified, Riak will assign a random key to the object. If no
bucket type is assigned, Riak will assign
default, which means that the default bucket configuration will be used.
Request
message RpbPutReq {
required bytes bucket = 1;
optional bytes key = 2;
optional bytes vclock = 3;
required RpbContent content = 4;
optional uint32 w = 5;
optional uint32 dw = 6;
optional bool return_body = 7;
optional uint32 pw = 8;
optional bool if_not_modified = 9;
optional bool if_none_match = 10;
optional bool return_head = 11;
optional uint32 timeout = 12;
optional bool asis = 13;
optional bool sloppy_quorum = 14;
optional uint32 n_val = 15;
optional bytes type = 16;
}
Required Parameters
| Parameter | Description |
|---|---|
bucket |
The name of the bucket, in bytes, in which the key/value is to reside |
content |
The new or updated contented of the object. Uses the same RpbContent message returned as part of an RpbGetResp message, documented in PBC Fetch Object |
Optional Parameters
All of the optional parameters below have default values determined on a per-bucket basis. Please refer to the documentation on setting bucket properties for more information.
Furthermore, you can assign an integer value to the w, dw, pr, and pw,
provided that that integer value is less than or equal to N, or a special
value denoting one (4294967295-1), quorum (4294967295-2), all
(4294967295-3), or default (4294967295-4).
| Parameter | Description |
|---|---|
key |
The key to create/update. If not specified, Riak will generate a random key and return that key as part of the response to that request. |
vclock |
Opaque vector clock provided by an earlier RpbGetResp message. Omit if this is a new key or if you deliberately want to create a sibling. |
w |
Write quorum, i.e. how many replicas to write to before returning a successful response |
dw |
Durable write quorum, i.e. how many replicas to commit to durable storage before returning a successful response |
return_body |
Whether to return the contents of the now-stored object. Defaults to false. |
pw |
Primary write quorum, i.e. how many primary nodes must be up when the write is attempted |
return_head |
Return the metadata for the now-stored object without returning the value of the object |
timeout |
The timeout duration, in milliseconds, after which Riak will return an error message |
sloppy_quorum |
If this parameter is set to true, the next available node in the ring will accept requests if any primary node is unavailable |
n_val |
The number of nodes on which the value is to be stored |
The if_not_modified, if_none_match, and asis parameters are set
only for messages sent between nodes in a Riak cluster and should not be
set by Riak clients.
Response
message RpbPutResp {
repeated RpbContent contents = 1;
optional bytes vclock = 2;
optional bytes key = 3;
}
If return_body is set to true on the PUT request, the RpbPutResp
will contain the current object after the PUT completes, in contents,
as well as the object’s causal context, in the vclock
field. The key will be sent only if the server generated a random key
for the object.
If return_body is not set and no key is generated, the PUT response
will be empty.
Example
Request
Hex 00 00 00 1C 0B 0A 01 62 12 01 6B 22 0F 0A 0D 7B
22 66 6F 6F 22 3A 22 62 61 72 22 7D 28 02 38 01
Erlang <<0,0,0,28,11,10,1,98,18,1,107,34,15,10,13,123,34,102,111,111,34,58,34,
98,97,114,34,125,40,2,56,1>>
RpbPutReq protoc decode:
bucket: "b"
key: "k"
content {
value: "{"foo":"bar"}"
}
w: 2
return_body: true
Response
Hex 00 00 00 62 0C 0A 31 0A 0D 7B 22 66 6F 6F 22 3A
22 62 61 72 22 7D 2A 16 31 63 61 79 6B 4F 44 39
36 69 4E 41 68 6F 6D 79 65 56 6A 4F 59 43 38 AF
B0 A3 DE 04 40 90 E7 18 12 2C 6B CE 61 60 60 60
CA 60 CA 05 52 2C 2C E9 0C 86 19 4C 89 8C 79 AC
0C 5A 21 B6 47 F9 20 C2 6C CD 49 AC 0D 77 7C A0
12 FA 20 89 2C 00
Erlang <<0,0,0,98,12,10,49,10,13,123,34,102,111,111,34,58,34,98,97,114,34,125,
42,22,49,99,97,121,107,79,68,57,54,105,78,65,104,111,109,121,101,86,
106,79,89,67,56,175,176,163,222,4,64,144,231,24,18,44,107,206,97,96,
96,96,202,96,202,5,82,44,44,233,12,134,25,76,137,140,121,172,12,90,33,
182,71,249,32,194,108,205,73,172,13,119,124,160,18,250,32,137,44,0>>
RpbPutResp protoc decode:
contents {
value: "{"foo":"bar"}"
vtag: "1caykOD96iNAhomyeVjOYC"
last_mod: 1271453743
last_mod_usecs: 406416
}
vclock: "k316a```312`312005R,,351014206031L211214y254014Z!266G371
302l315I254rw|240022372 211,000"