router

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
  • func RegisterConsumerChannel(uuid string, accept []RoutingRule) *ConsumerChannel
  • func (cc *ConsumerChannel) Close()
  • func (cc *ConsumerChannel) Consume() Packet
• type ProducerChannel
  • func RegisterProducerChannel(uuid string, acceptAck bool) *ProducerChannel
  • func (pc *ProducerChannel) Close()
  • func (pc *ProducerChannel) Produce(packet Packet)
• type RouterConfig
• type RoutingRule

Functions

func GetCachedPacketCount

func GetCachedPacketCount() int

func GetChannelCacheLimit

func GetChannelCacheLimit() int

func GetChannelCount

func GetChannelCount() int

func GetConsumerChannelCount

func GetConsumerChannelCount() int

func GetIOCount

func GetIOCount() (int, int)

func GetProducerChannelCount

func GetProducerChannelCount() int

func Init

func Init(cfg RouterConfig)

func Start

func Start(cvts []Converter)

Types

type Channel

type Channel struct {
	UUID   string
	Buffer Buffer
}

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
}

type RoutingRule

type RoutingRule struct {
	From       string         `json:"from"`
	FromRegexp *regexp.Regexp `json:"-"`
	To         string         `json:"to"`
	ToRegexp   *regexp.Regexp `json:"-"`
	Formats    []Format       `json:"formats"`
}