Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ShipperKafka ¶
type ShipperKafka struct {
// contains filtered or unexported fields
}
func NewShipperKafka ¶
func NewShipperKafka(mh *handler.ShipperKafka) *ShipperKafka
func (*ShipperKafka) Close ¶
func (m *ShipperKafka) Close()
func (*ShipperKafka) Consume ¶
func (m *ShipperKafka) Consume(ctx context.Context)
Source Files
Click to show internal directories.
Click to hide internal directories.