Documentation ¶
Overview ¶
Dozer: kafka protocol module
Index ¶
- type Conn
- type DozerProtocolKafka
- func (p *DozerProtocolKafka) Close() error
- func (p *DozerProtocolKafka) Dial(typ, host string, port int64) (uint64, error)
- func (p *DozerProtocolKafka) Init(args ...string) error
- func (p *DozerProtocolKafka) RecvFrom(id uint64, dest string, messages chan []byte, quit chan bool) error
- func (p *DozerProtocolKafka) SendTo(id uint64, dest string, messages chan []byte, quit chan bool) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DozerProtocolKafka ¶
Kafka protocol type.
func (*DozerProtocolKafka) Close ¶
func (p *DozerProtocolKafka) Close() error
Close - Disconnect from the kafka broker.
func (*DozerProtocolKafka) Dial ¶
func (p *DozerProtocolKafka) Dial(typ, host string, port int64) (uint64, error)
Dial - connect to a kafka broker
func (*DozerProtocolKafka) Init ¶
func (p *DozerProtocolKafka) Init(args ...string) error
Init - intialize the kafka protocol
Click to show internal directories.
Click to hide internal directories.