Riak S2 Client

Erlang client for Riak S2.
You can view API documentation here.
Since Riak S2 mimics Amazon S3 API, that documentation could also be helpful:
service,
bucket,
object,
error.

How To Use

Build and run the docker container.
The build script will create a user for you and store all information
required for connection to the .develop-environment file.

$ ./run-docker.sh

Now we have Riak S2 initialized and started within container.
To build and start playing with the library, execute following commands in the shell:

$ make app shell

Here basic operations that you can perform. Refer to documentation to get to know more.

%% Initializing connection to Riak S2.
{ok, S, _} = erl_scan:string(os:getenv("DEVELOP_ENVIRONMENT")),
{ok, Conf} = erl_parse:parse_term(S),
#{s2_user := Opts, s2_http := #{host := Host, port := Port}} = Conf,
{ok, Pid} = gun:open(Host, Port, #{protocols => [http]}).
%% Creating a bucket, uploading an object and get it back
riaks2c_bucket:await_put(Pid, riaks2c_bucket:put(Pid, <<"test-bucket">>, Opts)),
riaks2c_object:await_put(Pid, riaks2c_object:put(Pid, <<"test-bucket">>, <<"test_file">>, <<42>>, Opts)),
riaks2c_object:expect_get(Pid, riaks2c_object:get(Pid, <<"test-bucket">>, <<"test_file">>, Opts)).
%% [<<42>>]
%% Listing buckets
riaks2c_bucket:expect_list(Pid, riaks2c_bucket:list(Pid, Opts)).
%% {'ListAllMyBucketsResult',[],
%%   {'CanonicalUser',[],
%%     <<"9897a3ea1c87262d4726b28b3e41c1e70bc9e20f54acdc12c5081e62f67b3323">>,
%%     <<"user">>},
%%   {'ListAllMyBucketsList',[],
%%     [{'ListAllMyBucketsEntry',[],<<"test-bucket">>,
%%       <<"2016-11-04T09:47:47.000Z">>}]}}
%% Listing objects
riaks2c_object:expect_list(Pid, riaks2c_object:list(Pid, <<"test-bucket">>, Opts)).
%% {'ListBucketResult',[],
%%   undefined,<<"test-bucket">>,[],[],
%%   undefined,1000,[],false,
%%   [{'ListEntry',[],
%%     <<"test_file">>,<<"2016-11-04T09:47:47.000Z">>,
%%     <<"\"9a0364b9e99bb480dd25e1f0284c8555\"">>,<<"7">>,
%%     <<"STANDARD">>,
%%     {'CanonicalUser',[],
%%       <<"9897a3ea1c87262d4726b28b"...>>,
%%       <<"user">>}}],
%%   undefined}
%% Cleaning up
riaks2c_object:await_remove(Pid, riaks2c_object:remove(Pid, <<"test-bucket">>, <<"test_file">>, Opts)),
riaks2c_bucket:await_remove(Pid, riaks2c_bucket:remove(Pid, <<"test-bucket">>, Opts)).

Troubleshooting

Using Docker container with Riak S2 on macOS, you can start getting “RequestTimeTooSkewed” error messages.
It happens because Docker synchronizes container’s time with its host OS
(which is Linux OS managed by docker-machine and isn’t macOS).
It can be fixed in this way:

$ docker-machine ssh
$ sudo ntpclient -s -h time.apple.com

License

The source code is provided under the terms of the MIT license.