common

Documentation

Index

• Constants
• func PrefixedProcessBackwardsQueue(processorName, prefix string) string
• func PrefixedProcessForwardsQueue(processorName, prefix string) string
• func ProcessBackwardsQueue(processorName string) string
• func ProcessForwardsQueue(processorName string) string
• func ProcessQueue(processorName string) string
• type BlockProcessor
• type Processor
• type QueueInfo

Constants

const (
	BACKWARDS_MODE = "backwards"
	FORWARDS_MODE  = "forwards"
)

Functions

func PrefixedProcessBackwardsQueue

func PrefixedProcessBackwardsQueue(processorName, prefix string) string

PrefixedProcessBackwardsQueue returns the backwards process queue name with prefix.

func PrefixedProcessForwardsQueue

func PrefixedProcessForwardsQueue(processorName, prefix string) string

PrefixedProcessForwardsQueue returns the forwards process queue name with prefix.

func ProcessBackwardsQueue

func ProcessBackwardsQueue(processorName string) string

ProcessBackwardsQueue returns the backwards process queue name for a processor.

func ProcessForwardsQueue

func ProcessForwardsQueue(processorName string) string

ProcessForwardsQueue returns the forwards process queue name for a processor.

func ProcessQueue

func ProcessQueue(processorName string) string

ProcessQueue returns the process 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.

type Processor

type Processor interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Name() string
}

Processor defines the main interface for block processors.

type QueueInfo

type QueueInfo struct {
	Name     string
	Priority int
}

QueueInfo contains information about a processor queue.