handler

Documentation

Index

• func New(params Params) nsq.Handler
• type Handler
• type Params

Functions

func New

func New(params Params) nsq.Handler

New handler for NSQ. nolint:ireturn

Types

type Handler

type Handler interface {
	Handle(ctx context.Context, message *message.Message) error
}

Handler for NSQ.

type Params

type Params struct {
	Handler    Handler
	Compressor compressor.Compressor
	Marshaller marshaller.Marshaller
}

Params for handler.