Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

plugin #5

Merged
merged 26 commits into from
May 2, 2022
Merged
Changes from 1 commit
Commits
Show all changes
26 commits
Select commit Hold shift + click to select a range
d853f40
gomod: bump codec
nicolasparada Apr 18, 2022
f378cd5
plugin: new plugin pkg
nicolasparada Apr 18, 2022
f3f3df8
plugin: add examples
nicolasparada Apr 18, 2022
d343e9a
plugin: renames and msgpack type fixes
nicolasparada Apr 19, 2022
cd9bc03
plugin: docker file
nicolasparada Apr 19, 2022
4f2efc3
makefile
nicolasparada Apr 19, 2022
b2f1ce6
make local plugins
nicolasparada Apr 19, 2022
42110e7
plugin: check flb time size
nicolasparada Apr 20, 2022
53c1f21
plugin: tag per message
nicolasparada Apr 20, 2022
874bd4e
switch to enterprise advanced docker image
nicolasparada Apr 20, 2022
ba46271
configure fluent bit log level to info
nicolasparada Apr 20, 2022
6e90343
plugin: stop on ctx done
nicolasparada Apr 20, 2022
2d7e2ba
plugin: ctx done checks
nicolasparada Apr 20, 2022
8a77b2f
plugin: rename output flush
nicolasparada Apr 25, 2022
d3cef77
plugin: remove writer reader interfaces
nicolasparada Apr 25, 2022
8f39dd1
plugin: test
nicolasparada Apr 28, 2022
c65f9cc
plugin: constant ftime size
nicolasparada Apr 28, 2022
8953ade
plugin: move dockerfile for tests
nicolasparada Apr 28, 2022
5c21858
plugin: handle msgpack handler bytes ext error
nicolasparada Apr 28, 2022
bcdf4ac
input: silently ignore error
nicolasparada Apr 28, 2022
a78b8eb
output: input: silently ignore error
nicolasparada Apr 28, 2022
4007a3e
plugin: remove unnecessary docker platform from tests
nicolasparada Apr 28, 2022
8157927
plugin: rename ftime to big endian time
nicolasparada Apr 28, 2022
14c31f3
plugin: indent code comment
nicolasparada Apr 28, 2022
a4a107c
plugin: rename calyptia fluent-bit image
nicolasparada May 2, 2022
d86ccf8
todo
nicolasparada May 2, 2022
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
todo
nicolasparada committed May 2, 2022
commit d86ccf8d68f03b2343c97df4bf1d85b80734059f
1 change: 1 addition & 0 deletions input/encoder.go
Original file line number Diff line number Diff line change
@@ -58,6 +58,7 @@ func NewEncoder() *FLBEncoder {
enc := new(FLBEncoder)
enc.handle = new(codec.MsgpackHandle)
enc.handle.WriteExt = true
// TODO: handle error.
_ = enc.handle.SetBytesExt(reflect.TypeOf(FLBTime{}), 0, &FLBTime{})

return enc
1 change: 1 addition & 0 deletions output/decoder.go
Original file line number Diff line number Diff line change
@@ -60,6 +60,7 @@ func NewDecoder(data unsafe.Pointer, length int) *FLBDecoder {

dec := new(FLBDecoder)
dec.handle = new(codec.MsgpackHandle)
// TODO: handle error.
_ = dec.handle.SetBytesExt(reflect.TypeOf(FLBTime{}), 0, &FLBTime{})

b = C.GoBytes(data, C.int(length))