balancer

Nov 30, 2022

Changes in this version

type Event

+ const AllConsumersSeen

+ const AllProducersSeen

Jun 20, 2022

Changes in this version

type State

+ const ConsumerAwaitingAndCloseFirst

+ const ProducerAwaitingAndCloseFirst

Sep 24, 2021

Changes in this version

+ type Balancer struct

+ func New(producerNetwork string, producerAddress string, consumerNetwork string, ...) *Balancer

+ func (b *Balancer) Start()

+ type ConsumerHandler struct

+ func NewConsumerHandler(balancer *Balancer, events chan<- Event, quit <-chan struct{}) *ConsumerHandler

+ type ConsumerWorker struct

+ func (w *ConsumerWorker) Start()

+ type Event int

+ const ConsumerClose

+ const ConsumerListenerReady

+ const LastConsumerClose

+ const LastProducerClose

+ const NewConsumer

+ const NewProducer

+ const ProducerClose

+ const ProducerListenerReady

+ type Handler interface

+ type Listener struct

+ func NewListenerFactory(handler Handler, network string, address string, readyCallback func()) *Listener

+ func (l Listener) Start()

+ type ProducerHandler struct

+ func NewProducerHandler(balancer *Balancer, events chan<- Event, quit <-chan struct{}) *ProducerHandler

+ type ProducerWorker struct

+ func (w *ProducerWorker) Start()

+ type State int

+ const ConsumerAndProcuder

+ const ConsumerAwaiting

+ const ConsumerCloseFirst

+ const ConsumerReady

+ const Initial

+ const NoConsumerAndNoProducer

+ const ProducerAwaiting

+ const ProducerCloseFirst

+ const ProducerReady

+ type StateEvent struct