broker

Documentation

Overview

Package broker implements the broker logic.

Index

• type BlockingChannel
  • func NewBlockingChannel(bufferLen int) *BlockingChannel
  • func (bc *BlockingChannel) Pop(ctx context.Context) events.Interface
  • func (bc *BlockingChannel) Push(evt events.Interface)
• type Broker
  • func New(logger logr.Logger, queue Queue, collectors map[string]subscriber.SubsChan, ...) (*Broker, error)
  • func (br *Broker) Start(ctx context.Context) error
• type Option
  • func WithAddress(addr string) Option
  • func WithTLS(certFilePath, keyFilePath string) Option
• type Queue

Types

type BlockingChannel

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

BlockingChannel implements the Queue interface using a channel.

func NewBlockingChannel

func NewBlockingChannel(bufferLen int) *BlockingChannel

NewBlockingChannel returns a BlockingChannel.

func (*BlockingChannel) Pop

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

Pop an event from the queue.

func (*BlockingChannel) Push

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

Push pushes an event to the queue.

type Broker

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

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

func New

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

New returns a new Broker.

func (*Broker) Start

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

type Option func(opt *options)

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

func WithAddress

func WithAddress(addr string) Option

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

func WithTLS

func WithTLS(certFilePath, keyFilePath string) Option

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

type Queue

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

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