Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActionsConsumer ¶
type ActionsConsumer struct {
BaseConsumer
}
ActionsConsumer ...
func NewActionsConsumer ¶
func NewActionsConsumer(url, clientName, consumerGroupName, topicName string) (*ActionsConsumer, error)
NewActionsConsumer ...
type BaseConsumer ¶
type BaseConsumer struct {
MetaData *sarama.MetadataResponse
AvailableOffsets *sarama.OffsetResponse
// contains filtered or unexported fields
}
BaseConsumer ...
func NewBaseConsumer ¶
func NewBaseConsumer(clientName, consumerGroupName, topicName string) (*BaseConsumer, error)
NewBaseConsumer ...
func (*BaseConsumer) FetchMetaData ¶
func (bc *BaseConsumer) FetchMetaData() error
FetchMetaData ...
func (*BaseConsumer) InitBroker ¶
func (bc *BaseConsumer) InitBroker(brokerHost string)
InitBroker ...
Source Files
Click to show internal directories.
Click to hide internal directories.