pkg

Documentation

Index

• Constants
• type Task
  • func NewTask(batchMerkleRoot [32]byte, batchDataPointer string) *Task
• type TaskSender
  • func NewTaskSender(config *config.TaskSenderConfig, avsWriter *chainio.AvsWriter) *TaskSender
  • func (ts *TaskSender) SendTask(task *Task) error

Constants

const RetryInterval = 1 * time.Second

Types

type Task

type Task struct {
	BatchMerkleRoot [32]byte
	// contains filtered or unexported fields
}

func NewTask

func NewTask(batchMerkleRoot [32]byte, batchDataPointer string) *Task

type TaskSender

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

func NewTaskSender

func NewTaskSender(config *config.TaskSenderConfig, avsWriter *chainio.AvsWriter) *TaskSender

func (*TaskSender) SendTask

func (ts *TaskSender) SendTask(task *Task) error