fluenttest

package module

v0.0.0-...-1d3e679 Latest Latest Go to latest Published: Oct 26, 2023 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bitdabbler/fluenttest

Links

Open Source Insights

README ¶

fluentd/fluenttest

Basic test utilities

an extremely minimalstic "fluentest.Server"
a FluentD fluenttest.Message object representing a decoded log payload for the FluentD Message event mode

Documentation ¶

Overview ¶

fluenttest provides Fluentd logging stack testing utilities.

Index ¶

type Message
- func (m *Message) DecodeMsgpack(dec *msgpack.Decoder) error
type TestServer
- func NewServer(network, host string) (*TestServer, error)
- func (s *TestServer) Shutdown()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Message ¶

type Message struct {
	Tag    string
	Time   time.Time
	Record map[string]any
}

func (*Message) DecodeMsgpack ¶

func (m *Message) DecodeMsgpack(dec *msgpack.Decoder) error

DecodeMsgpack deserializes the payload, which is expected to conform to the FLuentD Message event mode format. [

 	tag<string>,
	time<EventTime | int>,
	record<map[string]any>,
	option<optional map[string]any>

]

type TestServer ¶

type TestServer struct {
	Listener  net.Listener
	MessageCh chan *Message
	Network   string
	Port      int
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(network, host string) (*TestServer, error)

func (*TestServer) Shutdown ¶

func (s *TestServer) Shutdown()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL