worker

Documentation

Index

• type App
• type AppWorker
  • func NewAppWorker(appName string, handlers Handlers, bufferSize int, natsClient *nats.Client, ...) *AppWorker
  • func (a *AppWorker) Run(ctx context.Context)
• type Executor
• type Handler
• type HandlerFunc
• type Handlers
• 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 AppWorker

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

func NewAppWorker

func NewAppWorker(appName string, handlers Handlers, bufferSize int, natsClient *nats.Client, logger Logger) *AppWorker

func (*AppWorker) Run

func (a *AppWorker) Run(ctx context.Context)

type Executor

type Executor func(context.Context) (interface{}, error)

type Handler

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

TODO: Update function to return a pointer to a ResultMsg

type HandlerFunc

type HandlerFunc func([]byte, *nats.MsgMeta) (Executor, error)

type Handlers

type Handlers map[string]HandlerFunc

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
}

Deprecated: Use AppWorker instead

func NewWorker

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

Deprecated: Use NewAppWorker instead

func (*Worker) Run

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