Documentation
¶
Index ¶
- Constants
- func PrefixedProcessBackwardsQueue(processorName, prefix string) string
- func PrefixedProcessForwardsQueue(processorName, prefix string) string
- func PrefixedVerifyBackwardsQueue(processorName, prefix string) string
- func PrefixedVerifyForwardsQueue(processorName, prefix string) string
- func ProcessBackwardsQueue(processorName string) string
- func ProcessForwardsQueue(processorName string) string
- func ProcessQueue(processorName string) string
- func VerifyBackwardsQueue(processorName string) string
- func VerifyForwardsQueue(processorName string) string
- func VerifyQueue(processorName string) string
- type BlockProcessor
- type Processor
- type QueueInfo
Constants ¶
const ( BACKWARDS_MODE = "backwards" FORWARDS_MODE = "forwards" )
Variables ¶
This section is empty.
Functions ¶
func PrefixedProcessBackwardsQueue ¶ added in v0.0.5
PrefixedProcessBackwardsQueue returns the backwards process queue name with prefix.
func PrefixedProcessForwardsQueue ¶ added in v0.0.5
PrefixedProcessForwardsQueue returns the forwards process queue name with prefix.
func PrefixedVerifyBackwardsQueue ¶ added in v0.0.5
PrefixedVerifyBackwardsQueue returns the backwards verify queue name with prefix.
func PrefixedVerifyForwardsQueue ¶ added in v0.0.5
PrefixedVerifyForwardsQueue returns the forwards verify queue name with prefix.
func ProcessBackwardsQueue ¶
ProcessBackwardsQueue returns the backwards process queue name for a processor.
func ProcessForwardsQueue ¶
ProcessForwardsQueue returns the forwards process queue name for a processor.
func ProcessQueue ¶
ProcessQueue returns the process queue name for a processor (deprecated - use mode-specific queues).
func VerifyBackwardsQueue ¶
VerifyBackwardsQueue returns the backwards verify queue name for a processor.
func VerifyForwardsQueue ¶
VerifyForwardsQueue returns the forwards verify queue name for a processor.
func VerifyQueue ¶
VerifyQueue returns the verify queue name for a processor (deprecated - use mode-specific queues).
Types ¶
type BlockProcessor ¶
type BlockProcessor interface {
Processor
ProcessNextBlock(ctx context.Context) error
// Queue management
GetQueues() []QueueInfo
GetHandlers() map[string]asynq.HandlerFunc
// Task enqueueing (for internal use)
EnqueueTask(ctx context.Context, task *asynq.Task, opts ...asynq.Option) error
// Processing mode configuration
SetProcessingMode(mode string)
}
BlockProcessor handles block discovery and processing.
Source Files