Documentation
¶
Index ¶
- type Consumer
- type Environment
- type MockConsumer
- func (mc *MockConsumer) Close() (err error)
- func (mc *MockConsumer) Commit() ([]kafka.TopicPartition, error)
- func (mc *MockConsumer) CommitMessage(m *kafka.Message) ([]kafka.TopicPartition, error)
- func (mc *MockConsumer) Poll(timeout int) (event kafka.Event)
- func (mc *MockConsumer) SubscribeTopics(topics []string, rebalanceCb kafka.RebalanceCb) (err error)
- type MockEvent
- type Reader
- type Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer interface {
Poll(timeout int) (event kafka.Event)
Commit() ([]kafka.TopicPartition, error)
Close() (err error)
}
Consumer interface
type Environment ¶
Environment represents the current inspr environment
func GetEnvironment ¶
func GetEnvironment() *Environment
GetEnvironment returns the current inspr environment
func RefreshEnviromentVariables ¶
func RefreshEnviromentVariables() *Environment
RefreshEnviromentVariables "refreshes" the value of kafka environment variables. This was develop for testing and probably sholdn't be used in other cases.
type MockConsumer ¶
type MockConsumer struct {
// contains filtered or unexported fields
}
MockConsumer mock
func (*MockConsumer) Commit ¶
func (mc *MockConsumer) Commit() ([]kafka.TopicPartition, error)
Commit mock
func (*MockConsumer) CommitMessage ¶
func (mc *MockConsumer) CommitMessage(m *kafka.Message) ([]kafka.TopicPartition, error)
CommitMessage mock
func (*MockConsumer) SubscribeTopics ¶
func (mc *MockConsumer) SubscribeTopics(topics []string, rebalanceCb kafka.RebalanceCb) (err error)
SubscribeTopics mock
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader reads/commit messages from the channels defined in the env
func (*Reader) NewSingleChannelConsumer ¶
NewSingleChannelConsumer creates a consumer for a single Kafka channel on the reader's consumers map.
func (*Reader) ReadMessage ¶
func (reader *Reader) ReadMessage(channel string) (models.BrokerData, error)
ReadMessage reads message by message. Returns channel the message belongs to, the message and an error if any occurred.
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
Writer defines an interface for writing messages
func (*Writer) WriteMessage ¶
WriteMessage receives a message and sends it to the topic defined by the given channel
Source Files