worker

Documentation

Overview

Package worker implements a message-based worker for the boomer service.

Index

• type Connection
• type Worker
  • func New(c Connection) (*Worker, error)
  • func (w *Worker) Handler(msg *nats.Msg)

Types

type Connection

type Connection interface {
	Subscribe(subj string, cb nats.MsgHandler) (*nats.Subscription, error)
}

Connection is an interface for subscribing to messages

type Worker

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

Worker processes and responds to requests from a message queue

func New

func New(c Connection) (*Worker, error)

New creates a new boomer worker

func (*Worker) Handler

func (w *Worker) Handler(msg *nats.Msg)

Handler processes and responds to the nats.Msg.