services

Documentation

Index

• Constants
• func RunQueueCleaner(cfg config.Config, ctx context.Context)
• func RunScheduler(cfg config.Config, ctx context.Context)
• type Scheduler
  • func NewScheduler(cfg config.Config) Scheduler

Constants

const (
	TxPerPageLimit       = 100
	BlockHeightCursorKey = "block_height_cursor"
	RunnerName           = "scheduler_catchup"
	InvalidHeightMessage = "codespace sdk code 26: invalid height"
)

Functions

func RunQueueCleaner

func RunQueueCleaner(cfg config.Config, ctx context.Context)

func RunScheduler

func RunScheduler(cfg config.Config, ctx context.Context)

Types

type Scheduler

type Scheduler interface {
	ScheduleRelays(
		ctx context.Context,
		confirmationID string,
		transferIndexes []string,
	) error
}

func NewScheduler

func NewScheduler(cfg config.Config) Scheduler