consumers

Documentation

Index

• type JobConsumer
  • func NewJobConsumer() (*JobConsumer, error)
  • func (jc *JobConsumer) Close() error
  • func (jc *JobConsumer) Worker(id int)

Types

type JobConsumer

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

JobConsumer consumed jobs messages from a Kafka topic and send them as HTTP POST request.

func NewJobConsumer

func NewJobConsumer() (*JobConsumer, error)

NewJobConsumer returns a new job consumer.

func (*JobConsumer) Close

func (jc *JobConsumer) Close() error

Close the consumer.

func (*JobConsumer) Worker

func (jc *JobConsumer) Worker(id int)

Worker is the main goroutine that is calling handleMsg