types

Oct 30, 2022

Changes in this version

type WorkerHandler

+ Configs map[string]interface{}

type WorkerHandlerOptionFunc

+ func WorkerHandlerOptionAddConfig(key string, value interface{}) WorkerHandlerOptionFunc

Jan 16, 2022

Changes in this version

type WorkerHandler

+ HandlerFuncs []WorkerHandlerFunc

type WorkerHandlerOptionFunc

+ func WorkerHandlerOptionAddHandlers(handlerFuncs ...WorkerHandlerFunc) WorkerHandlerOptionFunc

Jul 29, 2021

Changes in this version

+ type WorkerHandler struct

+ AutoACK bool

+ DisableTrace bool

+ ErrorHandler []WorkerErrorHandler

+ HandlerFunc WorkerHandlerFunc

+ Pattern string

+ type WorkerHandlerOptionFunc func(*WorkerHandler)

+ func WorkerHandlerOptionAddErrorHandler(errHandlers ...WorkerErrorHandler) WorkerHandlerOptionFunc

+ func WorkerHandlerOptionAutoACK(auto bool) WorkerHandlerOptionFunc

+ func WorkerHandlerOptionDisableTrace(disable bool) WorkerHandlerOptionFunc

May 4, 2021

Changes in this version

+ const GRPC

+ const GraphQL

+ const Kafka

+ const PostgresListener

+ const REST

+ const RabbitMQ

+ const RedisSubscriber

+ const Scheduler

+ const TaskQueue

+ type Database int

+ const ElasticSearch

+ const Mongo

+ const Redis

+ const SQL

+ type MiddlewareFunc func(context.Context) context.Context

+ type MiddlewareGroup map[string][]MiddlewareFunc

+ func (mw MiddlewareGroup) Add(fullMethod string, middlewareFunc ...MiddlewareFunc)

+ func (mw MiddlewareGroup) AddProto(protoDesc protoreflect.FileDescriptor, handler interface{}, ...)

+ type Module string

+ type Server string

+ type Service string

+ type Worker string

+ type WorkerErrorHandler func(ctx context.Context, workerType Worker, workerName string, message []byte, ...)

+ type WorkerHandlerFunc func(ctx context.Context, message []byte) error

+ type WorkerHandlerGroup struct

+ Handlers []struct{ ... }

+ func (m *WorkerHandlerGroup) Add(pattern string, handlerFunc WorkerHandlerFunc, ...)