55 nmsg_input_type_stream,
58 nmsg_input_type_callback,
70nmsg_input_open_file(
int fd);
80nmsg_input_open_sock(
int fd);
90nmsg_input_open_zmq(
void *s);
120nmsg_input_open_zmq_endpoint(
void *zmq_ctx,
const char *ep);
135nmsg_input_open_callback(nmsg_cb_message_read cb,
void *user);
150nmsg_input_open_null(
void);
163nmsg_input_open_pres(
int fd, nmsg_msgmod_t msgmod);
175nmsg_input_open_json(
int fd);
189nmsg_input_open_pcap(nmsg_pcap_t pcap, nmsg_msgmod_t msgmod);
199nmsg_input_close(nmsg_input_t *input);
218nmsg_input_loop(nmsg_input_t input,
int count, nmsg_cb_message cb,
void *user);
226nmsg_input_breakloop(nmsg_input_t input);
243nmsg_input_read(nmsg_input_t input, nmsg_message_t *msg);
272nmsg_input_read_null(nmsg_input_t input, uint8_t *buf,
size_t buf_len,
273 struct timespec *ts, nmsg_message_t **msg,
size_t *n_msg);
290nmsg_input_set_filter_msgtype(nmsg_input_t input,
291 unsigned vid,
unsigned msgtype);
303nmsg_input_set_filter_msgtype_byname(nmsg_input_t input,
304 const char *vname,
const char *mname);
316nmsg_input_set_filter_source(nmsg_input_t input,
unsigned source);
328nmsg_input_set_filter_operator(nmsg_input_t input,
unsigned operator_);
340nmsg_input_set_filter_group(nmsg_input_t input,
unsigned group);
354nmsg_input_set_blocking_io(nmsg_input_t input,
bool flag);
372nmsg_input_set_byte_rate(nmsg_input_t input,
size_t rate);
388nmsg_input_set_verify_seqsrc(nmsg_input_t input,
bool verify);
404nmsg_input_get_count_container_received(nmsg_input_t input, uint64_t *count);
421nmsg_input_get_count_container_dropped(nmsg_input_t input, uint64_t *count);