Affected by GO-2025-4252 and 5 other vulnerabilities

GO-2025-4252: Buffer Overflow via Malformed Syslog Message or Malicious Tokenizer Pattern in github.com/elastic/beats

GO-2025-4253: Elasticsearch Packetbeat has Excessive Allocation of Memory and CPU via Malicious IPv4 Fragments in github.com/elastic/beats

GO-2026-4360: Metricbeat affected by multiple denial of service vulnerabilities in github.com/elastic/beats

GO-2026-4789: Packetbeat does not properly validate an array index in multiple protocol parser components in github.com/elastic/beats

GO-2026-4790: Metricbeat Allocates Memory with Excessive Size Value Leading to Denial of Service in github.com/elastic/beats

The highest tagged major version is v7.

memqueue

package

v6.0.0+incompatible Latest Latest Go to latest Published: Nov 7, 2017 License: Apache-2.0 Imports: 12 Imported by: 426

Details

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

Repository

github.com/elastic/beats

Links

Open Source Insights

Documentation ¶

Overview ¶

Package memqueue provides an in-memory queue.Queue implementation for use with the publisher pipeline. The queue implementation is registered as queue type "mem".

Index ¶

type Broker
- func NewBroker(settings Settings) *Broker
type Settings

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Broker ¶

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

func NewBroker ¶

func NewBroker(
	settings Settings,
) *Broker

NewBroker creates a new broker based in-memory queue holding up to sz number of events. If waitOnClose is set to true, the broker will block on Close, until all internal workers handling incoming messages and ACKs have been shut down.

func (*Broker) BufferConfig ¶

func (b *Broker) BufferConfig() queue.BufferConfig

func (*Broker) Close ¶

func (b *Broker) Close() error

func (*Broker) Consumer ¶

func (b *Broker) Consumer() queue.Consumer

func (*Broker) Producer ¶

func (b *Broker) Producer(cfg queue.ProducerConfig) queue.Producer

type Settings ¶

type Settings struct {
	Eventer        queue.Eventer
	Events         int
	FlushMinEvents int
	FlushTimeout   time.Duration
	WaitOnClose    bool
}

Source Files ¶

View all Source files

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