Documentation
¶
Index ¶
- type Consumer
- func (self *Consumer) ConsumerConsume(b []byte, unused *struct{}) (err error)
- func (self *Consumer) ConsumerInterruptConsumption(interrupt common.ConsumptionInterrupt, unused *struct{}) (err error)
- func (self *Consumer) Log(s string, unused *struct{}) (err error)
- func (self *Consumer) Publish(unused struct{}, unused2 *struct{}) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func (*Consumer) ConsumerConsume ¶
func (*Consumer) ConsumerInterruptConsumption ¶
func (self *Consumer) ConsumerInterruptConsumption(interrupt common.ConsumptionInterrupt, unused *struct{}) (err error)
Source Files
Click to show internal directories.
Click to hide internal directories.