distributor

type CallBackFunc func(obj interface{}) int

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

type LoadBalancer interface {
	// Start load balancer
	Run(ctx context.Context)
	// Do the load balancing and distribute packets to workers
	Handle(obj interface{}) int
	// Return workers
	Workers() []*Worker
	// Set callback function for worker to do post processing
	SetCallBack(cb CallBackFunc)
}

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

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

type Worker struct {
	Name string

	Count int
	// contains filtered or unexported fields
}