initsequencer

Documentation

Index

• Constants
• type Controller
  • func NewController(config *config.Config, sequencerRepoPath string, env string) (self *Controller, err error)
• type NextBlock
  • func NewNextBlock(config *config.Config) (self *NextBlock)
  • func (self *NextBlock) WithLastSyncedBlock(lastSyncedBlock model.State) *NextBlock
• type Writer
  • func NewWriter(config *config.Config) (self *Writer)
  • func (self *Writer) WithDB(db *gorm.DB) *Writer
  • func (self *Writer) WithEnv(env string) *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

Constants

const (
	NETWORK_FOLDER          = "network"
	GENESIS_FOLDER          = "genesis"
	PREV_SORT_KEYS_FILE     = "prev_sort_keys.json"
	LAST_ARWEAVE_BLOCK_FILE = "arweave_block.json"
)

Types

type Controller

type Controller struct {
	*task.Task
}

func NewController

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

type NextBlock

type NextBlock struct {
	*task.Task

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

func NewNextBlock

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

func (*NextBlock) WithLastSyncedBlock

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

type Writer

type Writer struct {
	*task.Task

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

func NewWriter

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

func (*Writer) WithDB

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

func (*Writer) WithEnv

func (self *Writer) WithEnv(env string) *Writer

func (*Writer) WithInput

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

func (*Writer) WithLastSyncedBlock

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

func (*Writer) WithSequencerRepoPath

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