common

Documentation

Index

• Constants
• 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"
)

Functions

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)

func VerifyBackwardsQueue

func VerifyBackwardsQueue(processorName string) string

VerifyBackwardsQueue returns the backwards verify queue name for a processor

func VerifyForwardsQueue

func VerifyForwardsQueue(processorName string) string

VerifyForwardsQueue returns the forwards verify queue name for a processor

func VerifyQueue

func VerifyQueue(processorName string) string

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

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