worker

Documentation

Index

• type App
• type Handler
• type Logger
• type Worker
  • func NewWorker(natsClient *nats.Client, app App, logger Logger) *Worker
  • func (w *Worker) Run(ctx context.Context) error

Types

type App

type App interface {
	AppName() string
	Handlers() map[string]Handler
}

type Handler

type Handler func(context.Context, jetstream.Msg) error

TODO: Update function to return a pointer to a ResultMsg

type Logger

type Logger interface {
	// Log a debug statement
	Debugf(format string, v ...interface{})

	// Log an error with exact error
	Errf(err error, format string, v ...interface{})

	// Log an error
	Errorf(format string, v ...interface{})

	// Log a fatal error
	Fatalf(format string, v ...interface{})

	// Log an info statement
	Infof(format string, v ...interface{})

	// Log a notice statement
	Noticef(format string, v ...interface{})

	// Log a trace statement
	Tracef(format string, v ...interface{})

	// Log a warning statement
	Warnf(format string, v ...interface{})
}

type Worker

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

func NewWorker

func NewWorker(natsClient *nats.Client, app App, logger Logger) *Worker

func (*Worker) Run

func (w *Worker) Run(ctx context.Context) error