# Functions
NewTaskProcessor creates a new TaskProcessor instance ```go tp, err := NewTaskProcessor(
WithInstrumentationClient(ic), WithLogger(logger), WithRedisConnectionAddress("localhost:6379"), WithConcurrencyFactor(10),
)
if err != nil { log.Fatal(err) }
defer tp.Close() // start the worker asynchronously go func() { if err := tp.Start(handler); err != nil { log.Fatal(err) }
```.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
`ErrClientNotSet` is an error that is returned when the `client` property of the `TaskProcessor` struct is not set.
`ErrConcurrencyFactorNotSet` is an error that is returned when the `concurrencyFactor` property of the `TaskProcessor` struct is not set.
`ErrInstrumentationClientNotSet` is an error that is returned when the `instrumentationClient` property of the `TaskProcessor` struct is not set.
`ErrLoggerNotSet` is an error that is returned when the `logger` property of the `TaskProcessor` struct is not set.
`ErrTaskHandlerNotSet` is an error that is returned when the `taskHandler` property of the `TaskProcessor` struct is not set.
`ErrTaskNotSet` is an error that is returned when the `task` argument of the `EnqueueTask` method is not set.
`ErrWorkerNotSet` is an error that is returned when the `worker` property of the `TaskProcessor` struct is not set.
# Structs
No description provided by the author
# Interfaces
IProcessor is an interface that defines the methods that must be implemented by a task processor.
# Type aliases
Option is a function that is used to set properties of the TaskProcessor struct.
ProcessingInterval represents the various processing intervals for a recurring task.
`TaskProcessorHandler` is a type alias for a function that processes a task.