eventhub

package module

v0.95.0 Latest Latest Go to latest Published: Oct 20, 2026 License: Apache-2.0 Imports: 2 Imported by: 8

Details

Provides a NewNonBlocking event source to Subscribe and Emit.

[!NOTE]

This repository should be imported as code.cloudfoundry.org/eventhub.

See the Contributing.md for more information on how to contribute.

This repository is maintained by App Runtime Platform under Diego area.

[!IMPORTANT]

Content in this file is managed by the CI task sync-readme and is generated by CI following a convention.

This section is empty.

View Source

var ErrHubAlreadyClosed = errors.New("hub already closed")

View Source

var ErrReadFromClosedSource = errors.New("read from closed source")

View Source

var ErrSendToClosedSource = errors.New("send to closed source")

View Source

var ErrSlowConsumer = errors.New("slow consumer")

View Source

var ErrSourceAlreadyClosed = errors.New("source already closed")

View Source

var ErrSubscribedToClosedHub = errors.New("subscribed to closed hub")

This section is empty.

type Event interface{}

type Hub interface {
	Subscribe() (Source, error)
	Emit(Event)
	Close() error
}

func NewNonBlocking(consumerBufferSize int) Hub

type Source interface {
	Next() (Event, error)
	Close() error
	// contains filtered or unexported methods
}