scheduler

Documentation

Index

• type Scheduler
  • func NewScheduler(executionWindow int64) *Scheduler
  • func (s *Scheduler) Cancel(id string)
  • func (s *Scheduler) Schedule(id string, firstTimestamp, slot int64, task func()) error
• type Storage

Types

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

Scheduler implements the required scheduling logic for submitting Ethereum transactions using a slot-based algorithm

func NewScheduler

func NewScheduler(executionWindow int64) *Scheduler

NewScheduler - Creates new instance of Scheduler

func (*Scheduler) Cancel

func (s *Scheduler) Cancel(id string)

Cancel - Removes and cancels an already scheduled Transaction

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(id string, firstTimestamp, slot int64, task func()) error

Schedule - Schedules new Transaction for execution at the right leader elected slot

type Storage

type Storage struct {
	Executed bool
	Timer    *time.Timer
}