Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LoadDistributor ¶
type LoadDistributor struct {
PartitionsCount int
TopicToPartitionMap map[string]*LoadPartition
// contains filtered or unexported fields
}
func NewLoadDistributor ¶
func NewLoadDistributor(consumerProxyLoadBalancerChannel <-chan *consumer.Consumer) LoadDistributor
func (*LoadDistributor) GetPartition ¶
func (ld *LoadDistributor) GetPartition(topic string) *LoadPartition
Function to get partition and check if the load partition is present or not if its present it returns the load partition else it returns after creating a new load partition.
func (*LoadDistributor) Start ¶
func (ld *LoadDistributor) Start() error
type LoadPartition ¶
type LoadPartition struct {
// contains filtered or unexported fields
}
func (*LoadPartition) HandleSubscription ¶
func (lp *LoadPartition) HandleSubscription(cnsmr consumer.Consumer, topic messagequeue.TopicIdentifier)
func (*LoadPartition) ProcessStream ¶
func (lp *LoadPartition) ProcessStream(topic messagequeue.TopicIdentifier)
func (*LoadPartition) Start ¶
func (lp *LoadPartition) Start()
type LoadPartitionFactory ¶
type LoadPartitionFactory struct {
*LoadPartitionFactoryConfig
}
func NewLoadPartitionFactory ¶
func NewLoadPartitionFactory(config *LoadPartitionFactoryConfig) *LoadPartitionFactory
func (*LoadPartitionFactory) Produce ¶
func (lpf *LoadPartitionFactory) Produce( topicChannel <-chan string, consumerChannel <-chan consumer.Consumer, ) *LoadPartition
type LoadPartitionFactoryConfig ¶
type LoadPartitionFactoryConfig struct {
}
Source Files
Click to show internal directories.
Click to hide internal directories.