mw

README

mw

Multi Worker Golang

Example

    manager := mw.New()
    worker := mw.NewRabbitMQRouter(
		"handlerName",
		"queueName",
		conn,
		handler,
		mw.WithTimeout(timeout),
		mw.WithAutoCommit(),
		mw.WithMultiplierWorkerPool(2),
	)

    manager.Register(worker)
    manager.Run()

Documentation

Index

• func New() *manager
• func NewConnectRabbitMQ(uri string) (*amqp.Connection, error)
• type Event
• type HandlerFunction
• type RabbitMQRouterOptions
  • func WithAutoCommit() RabbitMQRouterOptions
  • func WithMultiplierWorkerPool(n int) RabbitMQRouterOptions
  • func WithTimeout(t time.Duration) RabbitMQRouterOptions
• type Router
  • func NewRabbitMQRouter(queue, name string, conn *amqp.Connection, handler HandlerFunction, ...) Router

Functions

func New

func New() *manager

func NewConnectRabbitMQ

func NewConnectRabbitMQ(uri string) (*amqp.Connection, error)

Types

type Event

type Event interface {
	SetContext(context.Context)
	Context() context.Context
	Bind(interface{}) error
	ID() string
}

type HandlerFunction

type HandlerFunction func(Event) error

type RabbitMQRouterOptions

type RabbitMQRouterOptions func(*rabbitMQRouter)

func WithAutoCommit

func WithAutoCommit() RabbitMQRouterOptions

func WithMultiplierWorkerPool

func WithMultiplierWorkerPool(n int) RabbitMQRouterOptions

func WithTimeout

func WithTimeout(t time.Duration) RabbitMQRouterOptions

type Router

type Router interface {
	Commit(Event) error
	Producer(chan<- Event)
	Handler() HandlerFunction
	Pool() int
}

func NewRabbitMQRouter

func NewRabbitMQRouter(queue, name string, conn *amqp.Connection, handler HandlerFunction, options ...RabbitMQRouterOptions) Router