initsequencer

package

v0.2.95 Latest Latest Go to latest Published: Nov 9, 2023 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/warp-contracts/syncer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Controller
- func NewController(config *config.Config, warpInternalRepoPath string, sequencerRepoPath string) (self *Controller, err error)
type FinishedBlock
- func NewFinishedBlock(config *config.Config) (self *FinishedBlock)
- func (self *FinishedBlock) WithDB(db *gorm.DB) *FinishedBlock
type Writer
- func NewWriter(config *config.Config, sequencerRepoPath string) (self *Writer)

Constants ¶

View Source

const (
	WARP_INTERNAL_REPO_CONFIG_PATH_FORMAT = "k8s/dev/sequencer-%d/config/"
	SEQUENCER_REPO_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
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Controller ¶

type Controller struct {
	*task.Task
}

func NewController ¶

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

type FinishedBlock ¶ added in v0.2.95

type FinishedBlock struct {
	*task.Task

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

func NewFinishedBlock ¶ added in v0.2.95

func NewFinishedBlock(config *config.Config) (self *FinishedBlock)

func (*FinishedBlock) WithDB ¶ added in v0.2.95

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

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

func (*Writer) WithWarpInternalRepoPath ¶ added in v0.2.95

func (self *Writer) WithWarpInternalRepoPath(warpInternalRepoPath string) *Writer

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL