Documentation ¶
Index ¶
- func GetCachedPacketCount() int
- func GetChannelCacheLimit() int
- func GetChannelCount() int
- func GetConsumerChannelCount() int
- func GetIOCount() (int, int)
- func GetProducerChannelCount() int
- func Init(cfg RouterConfig)
- func Start(cvts []Converter)
- type Channel
- type ConsumerChannel
- type ProducerChannel
- type RouterConfig
- type RoutingRule
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCachedPacketCount ¶
func GetCachedPacketCount() int
func GetChannelCacheLimit ¶
func GetChannelCacheLimit() int
func GetChannelCount ¶
func GetChannelCount() int
func GetConsumerChannelCount ¶
func GetConsumerChannelCount() int
func GetIOCount ¶
func GetProducerChannelCount ¶
func GetProducerChannelCount() int
func Init ¶
func Init(cfg RouterConfig)
Types ¶
type ConsumerChannel ¶
type ConsumerChannel struct { Channel Accept []RoutingRule HelpInfo *helpinfo.HelpInfo }
func RegisterConsumerChannel ¶
func RegisterConsumerChannel(uuid string, accept []RoutingRule) *ConsumerChannel
func (*ConsumerChannel) Close ¶
func (cc *ConsumerChannel) Close()
func (*ConsumerChannel) Consume ¶
func (cc *ConsumerChannel) Consume() Packet
type ProducerChannel ¶
type ProducerChannel struct { Channel AcknowledgeBuffer Buffer }
func RegisterProducerChannel ¶
func RegisterProducerChannel(uuid string, acceptAck bool) *ProducerChannel
func (*ProducerChannel) Close ¶
func (pc *ProducerChannel) Close()
func (*ProducerChannel) Produce ¶
func (pc *ProducerChannel) Produce(packet Packet)
type RouterConfig ¶
type RouterConfig struct {
BufferSize uint
}
Click to show internal directories.
Click to hide internal directories.