jobqueue

Documentation

Index

• type JobQueue
  • func NewJobQueue() *JobQueue
  • func (q *JobQueue) Close()
  • func (q *JobQueue) Jobs() <-chan *m.AlertingJob
  • func (q *JobQueue) QueueJob(job *m.AlertingJob)
• type KafkaPubSub
  • func NewKafkaPubSub(brokersStr, topic string, pub <-chan *m.AlertingJob, sub chan<- *m.AlertingJob) *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

Types

type JobQueue

type JobQueue struct {
	// contains filtered or unexported fields
}

func NewJobQueue

func NewJobQueue() *JobQueue

func (*JobQueue) Close

func (q *JobQueue) Close()

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