Module kinetic

create_stream(Payload) -> any()

create_stream(Payload, Opts) -> any()

delete_stream(Payload) -> any()

delete_stream(Payload, Opts) -> any()

describe_stream(Payload) -> any()

describe_stream(Payload, Opts) -> any()

get_records(Payload) -> any()

get_records(Payload, Opts) -> any()

get_shard_iterator(Payload) -> any()

get_shard_iterator(Payload, Opts) -> any()

list_streams(Payload) -> any()

list_streams(Payload, Opts) -> any()

merge_shards(Payload) -> any()

merge_shards(Payload, Opts) -> any()

put_record(Payload) -> any()

put_record(Payload, Opts) -> any()

put_records(Payload) -> any()

put_records(Payload, Opts) -> any()

split_shard(Payload) -> any()

split_shard(Payload, Opts) -> any()

start() -> ok | {error, any()}

start(Opts) -> any()

start(X1::normal | {takeover, node()} | {failover, node()}, Opts::any()) -> {ok, pid()}

stop() -> ok | {error, any()}

stop(X1::any()) -> ok