#ifndef __LIBTUBERIA_H__
#define __LIBTUBERIA_H__

typedef struct tube tube;
typedef struct tube_source tube_source;
typedef struct tube_stage tube_stage;

typedef void *(*tube_fetch)(void *opaque);
typedef void *(*tube_process)(void *element, void *opaque);
typedef void (*tube_sink)(void *element, void *opaque);
typedef void (*tube_free_element)(void *element);

tube_source *tube_source_alloc(int nslots, tube_fetch fetch, void *opaque, tube_free_element free_element);
tube_stage *tube_stage_alloc(int nslots, tube_process process, void *opaque, tube_free_element free_element);
void tube_stage_free(tube_stage **stage);
void tube_source_and_stages_free(tube_source **source);

int tube_stage_append(tube_source *source, tube_stage *stage);

tube *tube_create(tube_source *source, tube_sink sink, void *opaque);
int tube_start(tube *ctx);
int tube_stop(tube *ctx);
void tube_free(tube **ctx);

int tube_inject(tube *ctx, int timeout_ms, void *element);
void *tube_retrive(tube *ctx, int timeout_ms);
void tube_flush(tube *ctx);
void tube_drop(tube *ctx);

#endif //__LIBTUBERIA_H__