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.

bus

package

v6.2.2+incompatible Latest Latest Go to latest Published: Feb 15, 2018 License: Apache-2.0 Imports: 3 Imported by: 1,498

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 ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Bus ¶

type Bus interface {
	// Publish an event to the bus
	Publish(Event)

	// Subscribe to all events, filter them to the ones containing *all* the keys in filter
	Subscribe(filter ...string) Listener
}

Bus provides a common channel to emit and listen for Events

func New ¶

func New(name string) Bus

New initializes a new bus with the given name and returns it

type Event ¶

type Event common.MapStr

Event sent to the bus

type Listener ¶

type Listener interface {
	// Events channel
	Events() <-chan Event

	// Stop listening and removes itself from the bus
	Stop()
}

Listener retrieves Events from a Bus subscription until Stop is called

Source Files ¶

View all Source files

bus.go

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