int consumer_rotate_channel(struct consumer_socket *socket, uint64_t key,
struct consumer_output *output, bool is_metadata_channel);
int consumer_init(struct consumer_socket *socket,
int consumer_rotate_channel(struct consumer_socket *socket, uint64_t key,
struct consumer_output *output, bool is_metadata_channel);
int consumer_init(struct consumer_socket *socket,
int consumer_create_trace_chunk(struct consumer_socket *socket,
uint64_t relayd_id, uint64_t session_id,
int consumer_create_trace_chunk(struct consumer_socket *socket,
uint64_t relayd_id, uint64_t session_id,