Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPBackend ¶
type AMQPBackend struct {
// contains filtered or unexported fields
}
func NewAMQPBackend ¶
func NewAMQPBackend() *AMQPBackend
func (*AMQPBackend) Start ¶
func (q *AMQPBackend) Start(in <-chan *common.Message)
type KafkaBackend ¶
type KafkaBackend struct {
// contains filtered or unexported fields
}
func NewKafkaBackend ¶
func NewKafkaBackend() *KafkaBackend
func (*KafkaBackend) Start ¶
func (q *KafkaBackend) Start(in <-chan *common.Message)
type MQTTBackend ¶
type MQTTBackend struct {
// contains filtered or unexported fields
}
func NewMQTTBackend ¶
func NewMQTTBackend() *MQTTBackend
func (*MQTTBackend) Start ¶
func (q *MQTTBackend) Start(in <-chan *common.Message)
Click to show internal directories.
Click to hide internal directories.