plugins/in_tail/tail_file.c
/* Multiline flush callback: invoked every time some content is complete */
Multiline flush callback: invoked every time some content is complete
Multiline flush callback : invoked every time some content is complete
static int ml_flush_callback(struct flb_ml_parser *parser,
                             struct flb_ml_stream *mst,
                             void *data, char *buf_data, size_t buf_size)
{
    struct flb_tail_file *file = data;
    file->mult_records++;
    msgpack_sbuffer_write(&file->mult_sbuf, buf_data, buf_size);
    return 0;
}
static int ml_flush_callback ( struct flb_ml_parser * parser , struct flb_ml_stream * mst , void * data , char * buf_data , size_t buf_size ) { struct flb_tail_file * file = data ; file -> mult_records ++ ; msgpack_sbuffer_write ( & file -> mult_sbuf , buf_data , buf_size ) ; return 0 ; }
Multiline flush callback: invoked every time some content is complete
Multiline flush callback : invoked every time some content is complete
/* Enqueue the records in our file->multiline buffer */