transport

package

v0.9.4 Latest Latest Go to latest Published: Feb 10, 2026 License: MIT Imports: 9 Imported by: 0

Details

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

Repository

github.com/webmafia/fluentlog

Links

Open Source Insights

Documentation ¶

Index ¶

type CompressedPackedForwardMode
type Entry
type ForwardMode
type MessageMode
type Mode
type PackedForwardMode
type TransportPhase

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CompressedPackedForwardMode ¶

type CompressedPackedForwardMode struct {
	// contains filtered or unexported fields
}

func (*CompressedPackedForwardMode) Enter ¶

func (m *CompressedPackedForwardMode) Enter(origIter *msgpack.Iterator, e *Entry, br ringbuf.RingBufferReader, hasOptions bool) (err error)

func (*CompressedPackedForwardMode) Leave ¶

func (m *CompressedPackedForwardMode) Leave(origIter *msgpack.Iterator) (err error)

Leave implements Mode.

func (*CompressedPackedForwardMode) Next ¶

func (m *CompressedPackedForwardMode) Next(origIter *msgpack.Iterator, e *Entry) (err error)

Next implements Mode.

func (*CompressedPackedForwardMode) Rewind ¶

func (m *CompressedPackedForwardMode) Rewind(_ *msgpack.Iterator)

Rewind implements Mode.

func (*CompressedPackedForwardMode) String ¶

func (m *CompressedPackedForwardMode) String() string

String implements Mode.

type Entry ¶

type Entry struct {
	Tag       string
	Timestamp time.Time
	Record    *msgpack.Iterator
}

type ForwardMode ¶

type ForwardMode struct {
	// contains filtered or unexported fields
}

func (*ForwardMode) Enter ¶

func (m *ForwardMode) Enter(iter *msgpack.Iterator, e *Entry, items int, hasOptions bool) error

func (*ForwardMode) Leave ¶

func (m *ForwardMode) Leave(iter *msgpack.Iterator) (err error)

Leave implements Mode.

func (*ForwardMode) Next ¶

func (m *ForwardMode) Next(iter *msgpack.Iterator, e *Entry) (err error)

Next implements Mode.

func (*ForwardMode) Rewind ¶

func (m *ForwardMode) Rewind(iter *msgpack.Iterator)

Rewind implements Mode.

func (*ForwardMode) String ¶

func (m *ForwardMode) String() string

String implements Mode.

type MessageMode ¶

type MessageMode struct {
	// contains filtered or unexported fields
}

func (*MessageMode) Enter ¶

func (m *MessageMode) Enter(iter *msgpack.Iterator, e *Entry) error

func (*MessageMode) Leave ¶

func (m *MessageMode) Leave(iter *msgpack.Iterator) error

Leave implements Mode.

func (*MessageMode) Next ¶

func (m *MessageMode) Next(iter *msgpack.Iterator, e *Entry) (err error)

Next implements Mode.

func (*MessageMode) Rewind ¶

func (m *MessageMode) Rewind(iter *msgpack.Iterator)

Rewind implements Mode.

func (*MessageMode) String ¶

func (m *MessageMode) String() string

String implements Mode.

type Mode ¶

type Mode interface {
	fmt.Stringer
	Next(iter *msgpack.Iterator, e *Entry) error
	Leave(iter *msgpack.Iterator) error
	Rewind(iter *msgpack.Iterator)
}

type PackedForwardMode ¶

type PackedForwardMode struct {
	// contains filtered or unexported fields
}

func (*PackedForwardMode) Enter ¶

func (m *PackedForwardMode) Enter(origIter *msgpack.Iterator, e *Entry, r io.Reader, hasOptions bool) (err error)

func (*PackedForwardMode) Leave ¶

func (m *PackedForwardMode) Leave(origIter *msgpack.Iterator) (err error)

Leave implements Mode.

func (*PackedForwardMode) Next ¶

func (m *PackedForwardMode) Next(origIter *msgpack.Iterator, e *Entry) (err error)

Next implements Mode.

func (*PackedForwardMode) Rewind ¶

func (m *PackedForwardMode) Rewind(_ *msgpack.Iterator)

Rewind implements Mode.

func (*PackedForwardMode) String ¶

func (m *PackedForwardMode) String() string

String implements Mode.

type TransportPhase ¶

type TransportPhase struct {
	// contains filtered or unexported fields
}

func (*TransportPhase) Init ¶

func (t *TransportPhase) Init(iterPool *msgpack.IterPool, gzipPool *gzip.Pool, ack func(chunk string) error)

func (*TransportPhase) Next ¶

func (t *TransportPhase) Next(iter *msgpack.Iterator, e *Entry) error

func (*TransportPhase) Rewind ¶

func (t *TransportPhase) Rewind(iter *msgpack.Iterator)

Source Files ¶

View all Source files

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