initsequencer

Documentation

Index

• Constants
• type Controller
  • func NewController(config *config.Config, sequencerRepoPath string) (self *Controller, err error)
• type NextFinishedBlock
  • func NewNextFinishedBlock(config *config.Config) (self *NextFinishedBlock)
  • func (self *NextFinishedBlock) WithDB(db *gorm.DB) *NextFinishedBlock
• type Writer
  • func NewWriter(config *config.Config, sequencerRepoPath string) (self *Writer)
  • func (self *Writer) WithDB(db *gorm.DB) *Writer
  • func (self *Writer) WithInput(input chan *arweave.Block) *Writer
  • func (self *Writer) WithSequencerRepoPath(sequencerRepoPath string) *Writer

Constants

const (
	CONFIG_PATH_FORMAT      = "network/local/sequencer-%d/config/"
	PREV_SORT_KEYS_FILE     = "prev_sort_keys.json"
	LAST_ARWEAVE_BLOCK_FILE = "last_arweave_block.json"
	NUMBER_OF_NODES         = 3
)

Types

type Controller

type Controller struct {
	*task.Task
}

func NewController

func NewController(config *config.Config, sequencerRepoPath string) (self *Controller, err error)

type NextFinishedBlock

type NextFinishedBlock struct {
	*task.Task

	Output chan *arweave.NetworkInfo
	// contains filtered or unexported fields
}

func NewNextFinishedBlock

func NewNextFinishedBlock(config *config.Config) (self *NextFinishedBlock)

func (*NextFinishedBlock) WithDB

func (self *NextFinishedBlock) WithDB(db *gorm.DB) *NextFinishedBlock

type Writer

type Writer struct {
	*task.Task

	Output chan struct{}
	// contains filtered or unexported fields
}

func NewWriter

func NewWriter(config *config.Config, sequencerRepoPath string) (self *Writer)

func (*Writer) WithDB

func (self *Writer) WithDB(db *gorm.DB) *Writer

func (*Writer) WithInput

func (self *Writer) WithInput(input chan *arweave.Block) *Writer

func (*Writer) WithSequencerRepoPath

func (self *Writer) WithSequencerRepoPath(sequencerRepoPath string) *Writer