httpcommand

Documentation

Index

• Variables
• type CorsMiddleware
  • func NewCors(handler http.Handler) *CorsMiddleware
  • func (this *CorsMiddleware) ServeHTTP(res http.ResponseWriter, req *http.Request)
• type FactoryType
  • func (this FactoryType) NewConsumer(ctx context.Context, config util.Config, ...) (err error)
  • func (this FactoryType) NewProducer(ctx context.Context, config util.Config) (com.ProducerInterface, error)
• type LoggerMiddleWare
  • func NewLogger(handler http.Handler) *LoggerMiddleWare
  • func (this *LoggerMiddleWare) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Producer
  • func (this *Producer) Produce(topic string, message string) (err error)
  • func (this *Producer) ProduceWithKey(topic string, key string, message string) (err error)

Variables

var Factory = FactoryType{}

Types

type CorsMiddleware

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

func NewCors

func NewCors(handler http.Handler) *CorsMiddleware

func (*CorsMiddleware) ServeHTTP

func (this *CorsMiddleware) ServeHTTP(res http.ResponseWriter, req *http.Request)

type FactoryType

type FactoryType struct{}

func (FactoryType) NewConsumer

func (this FactoryType) NewConsumer(ctx context.Context, config util.Config, responseListener func(msg string) error, errorListener func(msg string) error) (err error)

func (FactoryType) NewProducer

func (this FactoryType) NewProducer(ctx context.Context, config util.Config) (com.ProducerInterface, error)

type LoggerMiddleWare

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

func NewLogger

func NewLogger(handler http.Handler) *LoggerMiddleWare

func (*LoggerMiddleWare) ServeHTTP

func (this *LoggerMiddleWare) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Producer

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

func (*Producer) Produce

func (this *Producer) Produce(topic string, message string) (err error)

func (*Producer) ProduceWithKey

func (this *Producer) ProduceWithKey(topic string, key string, message string) (err error)