Skip to content

Files

Latest commit

 

History

History

fluentforwardreceiver

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
internal
internal
 
 
testdata
testdata
 
 
Makefile
Makefile
 
 
README.md
README.md
 
 
ack.go
ack.go
 
 
ack_test.go
ack_test.go
 
 
collector.go
collector.go
 
 
config.go
config.go
 
 
config_test.go
config_test.go
 
 
conversion.go
conversion.go
 
 
conversion_test.go
conversion_test.go
 
 
doc.go
doc.go
 
 
documentation.md
documentation.md
 
 
factory.go
factory.go
 
 
factory_test.go
factory_test.go
 
 
generated_component_test.go
generated_component_test.go
 
 
generated_package_test.go
generated_package_test.go
 
 
go.mod
go.mod
 
 
go.sum
go.sum
 
 
heartbeat.go
heartbeat.go
 
 
heartbeat_test.go
heartbeat_test.go
 
 
metadata.yaml
metadata.yaml
 
 
parse_test.go
parse_test.go
 
 
receiver.go
receiver.go
 
 
receiver_test.go
receiver_test.go
 
 
server.go
server.go
 
 
server_test.go
server_test.go
 
 
timeext.go
timeext.go
 
 
timeext_test.go
timeext_test.go
 
 
util_test.go
util_test.go
 
 

README.md

Fluent Forward Receiver

Status
Stability beta: logs
Distributions contrib, k8s
Issues Open issues Closed issues
Code Owners @dmitryax

This receiver runs a TCP server that accepts events via the Fluent Forward protocol.

This receiver:

  • Does not support TLS or the handshake portion of the Forward protocol.
  • Does support acknowledgments of events that have the chunk option, as per the spec.
  • Supports all three event types (message, forward, packed forward, including compressed packed forward)
  • Supports listening on a Unix domain socket by making the listenAddress option of the form unix://<path to socket>.
  • If using TCP, it will start a UDP server on the same port to deliver heartbeat echos, as per the spec.

Here is a basic example config that makes the receiver listen on all interfaces on port 8006:

receivers:
  fluentforward:
    endpoint: 0.0.0.0:8006

Development

If you are working on this receiver and need to regenerate any of the message pack autogenerated code, just run go generate on this package and its subpackages. You can get the msgp binary by just running go get -u -t github.com/tinylib/msgp, and make sure the Go binary path is on your shell's PATH.