balancer

package

v0.5.0 Latest Latest Go to latest Published: Nov 30, 2022 License: GPL-3.0 Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cgi-fr/cat-balancer

Links

Open Source Insights

Documentation ¶

Index ¶

type Balancer
- func New(producerNetwork string, producerAddress string, consumerNetwork string, ...) *Balancer
- func (b *Balancer) Start()
type ConsumerHandler
- func NewConsumerHandler(balancer *Balancer, events chan<- Event, quit <-chan struct{}, ...) *ConsumerHandler
type ConsumerWorker
- func (w *ConsumerWorker) Start()
type Event
type Handler
type Listener
- func NewListenerFactory(handler Handler, network string, address string, readyCallback func()) *Listener
- func (l Listener) Start()
type ProducerHandler
- func NewProducerHandler(balancer *Balancer, events chan<- Event, quit <-chan struct{}, ...) *ProducerHandler
type ProducerWorker
- func (w *ProducerWorker) Start()
type State
type StateEvent

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Balancer ¶

type Balancer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New ¶

func New(producerNetwork string, producerAddress string,
	consumerNetwork string, consumerAddress string,
	producersPoolSize int, consumersPoolSize int,
	interval time.Duration) *Balancer

New Balancer service.

func (*Balancer) Start ¶

func (b *Balancer) Start()

Start the balancer Service and wait for clients.

type ConsumerHandler ¶

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

func NewConsumerHandler ¶

func NewConsumerHandler(
	balancer *Balancer,
	events chan<- Event,
	quit <-chan struct{},
	interval time.Duration) *ConsumerHandler

type ConsumerWorker ¶

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

func (*ConsumerWorker) Start ¶

func (w *ConsumerWorker) Start()

type Event ¶

type Event int

const (
	ProducerListenerReady Event = iota
	NewProducer
	AllProducersSeen
	ProducerClose
	LastProducerClose

	ConsumerListenerReady
	NewConsumer
	AllConsumersSeen
	ConsumerClose
	LastConsumerClose
)

type Handler ¶

type Handler interface {
	// contains filtered or unexported methods
}

type Listener ¶

type Listener struct {
	Handler
	// contains filtered or unexported fields
}

func NewListenerFactory ¶

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

func (Listener) Start ¶

func (l Listener) Start()

type ProducerHandler ¶

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

func NewProducerHandler ¶

func NewProducerHandler(
	balancer *Balancer,
	events chan<- Event,
	quit <-chan struct{},
	interval time.Duration) *ProducerHandler

type ProducerWorker ¶

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

func (*ProducerWorker) Start ¶

func (w *ProducerWorker) Start()

type State ¶

type State int

const (
	Initial State = iota
	ProducerReady
	ConsumerReady
	NoConsumerAndNoProducer
	ConsumerAwaiting
	ProducerAwaiting
	ConsumerAndProcuder
	ConsumerCloseFirst
	ProducerCloseFirst
	ConsumerAwaitingAndCloseFirst
	ProducerAwaitingAndCloseFirst
)

type StateEvent ¶

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

Source Files ¶

View all Source files

model.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL