initsequencer

package

v0.2.113 Latest Latest Go to latest Published: Nov 22, 2023 License: MIT Imports: 16 Imported by: 0

Details

View Source

const (
	GENESIS_PATH            = "genesis"
	PREV_SORT_KEYS_FILE     = "prev_sort_keys.json"
	LAST_ARWEAVE_BLOCK_FILE = "arweave_block.json"
)

This section is empty.

This section is empty.

type Controller struct {
	*task.Task
}

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

type NextBlock struct {
	*task.Task

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

func NewNextBlock(config *config.Config) (self *NextBlock)

func (self *NextBlock) WithLastSyncedBlock(lastSyncedBlock model.State) *NextBlock

type Writer struct {
	*task.Task

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

func NewWriter(config *config.Config) (self *Writer)

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

func (self *Writer) WithInput(input chan *listener.Payload) *Writer

func (self *Writer) WithLastSyncedBlock(lastSyncedBlock model.State) *Writer

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