Documentation
¶
Index ¶
- type JobQueue
- type KafkaPubSub
- func (ps *KafkaPubSub) Cleanup(_ sarama.ConsumerGroupSession) error
- func (ps *KafkaPubSub) Close()
- func (ps *KafkaPubSub) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
- func (ps *KafkaPubSub) Run()
- func (ps *KafkaPubSub) Setup(_ sarama.ConsumerGroupSession) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobQueue ¶
type JobQueue struct {
// contains filtered or unexported fields
}
func NewJobQueue ¶
func NewJobQueue() *JobQueue
func (*JobQueue) Jobs ¶
func (q *JobQueue) Jobs() <-chan *m.AlertingJob
func (*JobQueue) QueueJob ¶
func (q *JobQueue) QueueJob(job *m.AlertingJob)
type KafkaPubSub ¶
type KafkaPubSub struct {
// contains filtered or unexported fields
}
func NewKafkaPubSub ¶
func NewKafkaPubSub(brokersStr, topic string, pub <-chan *m.AlertingJob, sub chan<- *m.AlertingJob) *KafkaPubSub
func (*KafkaPubSub) Cleanup ¶
func (ps *KafkaPubSub) Cleanup(_ sarama.ConsumerGroupSession) error
func (*KafkaPubSub) Close ¶
func (ps *KafkaPubSub) Close()
func (*KafkaPubSub) ConsumeClaim ¶
func (ps *KafkaPubSub) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*KafkaPubSub) Run ¶
func (ps *KafkaPubSub) Run()
func (*KafkaPubSub) Setup ¶
func (ps *KafkaPubSub) Setup(_ sarama.ConsumerGroupSession) error
Source Files
Click to show internal directories.
Click to hide internal directories.