broker

package

v0.0.0-...-01af507 Latest Latest Go to latest Published: Jan 22, 2024 License: Apache-2.0 Imports: 14 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

Package broker implements the broker logic.

This section is empty.

This section is empty.

This section is empty.

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

BlockingChannel implements the Queue interface using a channel.

func NewBlockingChannel(bufferLen int) *BlockingChannel

NewBlockingChannel returns a BlockingChannel.

func (bc *BlockingChannel) Pop(ctx context.Context) events.Interface

Pop an event from the queue.

func (bc *BlockingChannel) Push(evt events.Interface)

Push pushes an event to the queue.

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

Broker receives events from the collectors and sends them to the subscribers.

func New(logger logr.Logger, queue Queue, collectors map[string]subscriber.SubsChan, opt ...Option) (*Broker, error)

New returns a new Broker.

func (br *Broker) Start(ctx context.Context) error

Start starts the grpc server and sends to subscribers the events received from the collectors.

type Option func(opt *options)

Option function used to set options when creating a new Broker instance.

func WithAddress(addr string) Option

WithAddress configures the binding address of the grpc server to the given value.

func WithTLS(certFilePath, keyFilePath string) Option

WithTLS configures the grpc server started by the broker to use TLS.

type Queue interface {
	Push(evt events.Interface)
	Pop(ctx context.Context) events.Interface
}

Queue used to dispatch events from the collectors to the broker.