Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ElasticsearchMessageEncoder ¶
func ElasticsearchMessageEncoder(topic string, key sarama.Encoder, message proto.Message) (*sarama.ProducerMessage, error)
ElasticsearchMessageEncoder defines the encoding from SubscribeResponse to sarama.ProducerMessage for Elasticsearch
Types ¶
type UnhandledMessageError ¶
type UnhandledMessageError struct {
// contains filtered or unexported fields
}
UnhandledMessageError is used for proto messages not matching the handled types
func (UnhandledMessageError) Error ¶
func (e UnhandledMessageError) Error() string
type UnhandledSubscribeResponseError ¶
type UnhandledSubscribeResponseError struct {
// contains filtered or unexported fields
}
UnhandledSubscribeResponseError is used for subscribe responses not matching the handled types
func (UnhandledSubscribeResponseError) Error ¶
func (e UnhandledSubscribeResponseError) Error() string
Source Files
Click to show internal directories.
Click to hide internal directories.