common

package

v0.0.10 Latest Latest Go to latest Published: Jun 20, 2025 License: GPL-3.0 Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ethpandaops/execution-processor

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

func PrefixedProcessBackwardsQueue ¶ added in v0.0.5

func PrefixedProcessBackwardsQueue(processorName, prefix string) string

PrefixedProcessBackwardsQueue returns the backwards process queue name with prefix

func PrefixedProcessForwardsQueue ¶ added in v0.0.5

func PrefixedProcessForwardsQueue(processorName, prefix string) string

PrefixedProcessForwardsQueue returns the forwards process queue name with prefix

func PrefixedVerifyBackwardsQueue ¶ added in v0.0.5

func PrefixedVerifyBackwardsQueue(processorName, prefix string) string

PrefixedVerifyBackwardsQueue returns the backwards verify queue name with prefix

func PrefixedVerifyForwardsQueue ¶ added in v0.0.5

func PrefixedVerifyForwardsQueue(processorName, prefix string) string

PrefixedVerifyForwardsQueue returns the forwards verify 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)

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL