handler

Documentation

Index

• func NewProducerHandler(cf *config.Configuration, p iface.KafkaProducer) iface.ProducerHandler
• type ProducerH
  • func (p *ProducerH) Close() error
  • func (p *ProducerH) JobsPostHandler(w http.ResponseWriter, r *http.Request)

Functions

func NewProducerHandler

func NewProducerHandler(cf *config.Configuration, p iface.KafkaProducer) iface.ProducerHandler

Types

type ProducerH

type ProducerH struct {
	KafkaProducer iface.KafkaProducer
}

func (*ProducerH) Close

func (p *ProducerH) Close() error

func (*ProducerH) JobsPostHandler

func (p *ProducerH) JobsPostHandler(w http.ResponseWriter, r *http.Request)