batch

package

v0.55.6 Latest Latest Go to latest Published: Jan 15, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gardener/logging

Links

Open Source Insights

Documentation ¶

Index ¶

type Batch
- func NewBatch(idLabelName model.LabelName, id uint64) *Batch
type Entry
type Stream

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Batch ¶

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

Batch holds pending logs waiting to be sent to Vali. The aggregation of the logs is used to reduce the number of push request to the Vali

func NewBatch ¶

func NewBatch(idLabelName model.LabelName, id uint64) *Batch

NewBatch returns a batch where the label set<ls>, timestamp<t> and the log line<line> are added to it.

func (*Batch) Add ¶

func (b *Batch) Add(ls model.LabelSet, t time.Time, line string)

Add an entry to the batch

func (*Batch) Age ¶

func (b *Batch) Age() time.Duration

Age of the batch since its creation

func (*Batch) GetStreams ¶ added in v0.43.0

func (b *Batch) GetStreams() map[string]*Stream

GetStreams returns batch streams

func (*Batch) SizeBytes ¶

func (b *Batch) SizeBytes() int

SizeBytes returns the current batch size in bytes

func (*Batch) SizeBytesAfter ¶

func (b *Batch) SizeBytesAfter(line string) int

SizeBytesAfter returns the size of the batch after the log of the next entry is added

func (*Batch) Sort ¶

func (b *Batch) Sort()

Sort sorts the entries in each stream by the timestamp

type Entry ¶

type Entry struct {
	Timestamp time.Time
	Line      string
}

Entry is a log entry with a timestamp.

type Stream ¶

type Stream struct {
	Labels  model.LabelSet
	Entries []Entry
	// contains filtered or unexported fields
}

Stream contains a unique labels set as a string and a set of entries for it. We are not using the proto generated version but this custom one so that we can improve serialization see benchmark.

Source Files ¶

View all Source files

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