FerricStore.Protocol (ferricstore_sdk v0.4.2)

@type frame() :: %{
  flags: non_neg_integer(),
  lane_id: non_neg_integer(),
  opcode: non_neg_integer(),
  request_id: non_neg_integer(),
  body_length: non_neg_integer()
}

Functions

command_payload(command, args \\ [], opts \\ [])

compact_flow_complete_many_payload(payload)

compact_flow_create_many_ids_payload(type, state, partition_key, ids, opts \\ [])

compact_flow_create_many_payload(payload)

custom_payload(payload)

decode_response_body(flags, opcode, body)

decode_response_header(header)

decode_value(bytes)

encode_request(opcode, request_id, payload, opts \\ [])

encode_value(value)

flag_compressed()

flag_custom_payload()

flag_more_chunks()

header_size()

magic()

opcode(name)

pipeline_payload(commands, opts \\ [])