mailbox

Documentation

Index

• type ChannelName
• type Mailbox
  • func ProvideMailbox(log logr.Logger) *Mailbox
  • func (s *Mailbox) Broadcast(channelName ChannelName, obj cache.Delta) error
  • func (s *Mailbox) RegisterListener(channelName ChannelName, ch chan cache.Delta)
  • func (s *Mailbox) Start(ctx context.Context) error
• type MailboxChannelProducer
  • func (w *MailboxChannelProducer) Start(ctx context.Context) error
• type MeterDefinitionChannelProducer
  • func ProvideMeterDefinitionChannelProducer(dictionary *stores.MeterDefinitionDictionary, mb *Mailbox, log logr.Logger) *MeterDefinitionChannelProducer
• type ObjectChannelProducer
  • func ProvideObjectChannelProducer(meterDefinitionStore *stores.MeterDefinitionStore, mb *Mailbox, ...) *ObjectChannelProducer

Types

type ChannelName

type ChannelName string

const (
	ObjectChannel          ChannelName = "ObjectChannel"
	MeterDefinitionChannel ChannelName = "MeterDefinitionChannel"
)

type Mailbox

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

func ProvideMailbox

func ProvideMailbox(log logr.Logger) *Mailbox

func (*Mailbox) Broadcast

func (s *Mailbox) Broadcast(channelName ChannelName, obj cache.Delta) error

func (*Mailbox) RegisterListener

func (s *Mailbox) RegisterListener(channelName ChannelName, ch chan cache.Delta)

func (*Mailbox) Start

func (s *Mailbox) Start(ctx context.Context) error

type MailboxChannelProducer

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

func (*MailboxChannelProducer) Start

func (w *MailboxChannelProducer) Start(ctx context.Context) error

Start will start processing pops from the dictionary. Will block

type MeterDefinitionChannelProducer

type MeterDefinitionChannelProducer struct {
	MailboxChannelProducer
}

func ProvideMeterDefinitionChannelProducer

func ProvideMeterDefinitionChannelProducer(
	dictionary *stores.MeterDefinitionDictionary,
	mb *Mailbox,
	log logr.Logger,
) *MeterDefinitionChannelProducer

type ObjectChannelProducer

type ObjectChannelProducer struct {
	MailboxChannelProducer
}

func ProvideObjectChannelProducer

func ProvideObjectChannelProducer(
	meterDefinitionStore *stores.MeterDefinitionStore,
	mb *Mailbox,
	log logr.Logger,
) *ObjectChannelProducer