tools

Documentation

Index

• Variables
• type KafkaProducer
  • func NewKafkaProducer(topic string, logger *zap.Logger, input chan<- *sarama.ProducerMessage) *KafkaProducer
  • func (k KafkaProducer) Send(block *pbcodec.Block)
• type LauncherWrapper
  • func NewLauncherWrapper(app launcher.App, logger *zap.Logger, producer sarama.AsyncProducer) *LauncherWrapper
  • func (l LauncherWrapper) Err() error
  • func (l LauncherWrapper) Run() error
  • func (l LauncherWrapper) Shutdown(err error)
  • func (l LauncherWrapper) Terminated() <-chan struct{}
  • func (l LauncherWrapper) Terminating() <-chan struct{}

Variables

var CheckCmd = &cobra.Command{Use: "check", Short: "Various checks for deployment, data integrity & debugging"}

CmdCheck is used in sf-ethereum-priv where additional checks are added.

var Cmd = &cobra.Command{Use: "tools", Short: "Developer tools related to sfeth"}

var DownloadFromFirehoseCmd = &cobra.Command{
	Use:     "download-from-firehose",
	Short:   "download blocks from firehose and save them to merged-blocks",
	Args:    cobra.ExactArgs(4),
	RunE:    downloadFromFirehoseE,
	Example: "sfeth tools download-from-firehose api.streamingfast.io 1000 2000 ./outputdir",
}

var Example = func(in string) string {
	return string(cli.Example(in))
}

var ExamplePrefixed = func(prefix, in string) string {
	return string(cli.ExamplePrefixed(prefix, in))
}

Types

type KafkaProducer

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

func NewKafkaProducer

func NewKafkaProducer(topic string, logger *zap.Logger, input chan<- *sarama.ProducerMessage) *KafkaProducer

func (KafkaProducer) Send

func (k KafkaProducer) Send(block *pbcodec.Block)

type LauncherWrapper

type LauncherWrapper struct {
	launcher.App
	// contains filtered or unexported fields
}

func NewLauncherWrapper

func NewLauncherWrapper(app launcher.App, logger *zap.Logger, producer sarama.AsyncProducer) *LauncherWrapper

func (LauncherWrapper) Err

func (l LauncherWrapper) Err() error

func (LauncherWrapper) Run

func (l LauncherWrapper) Run() error

func (LauncherWrapper) Shutdown

func (l LauncherWrapper) Shutdown(err error)

func (LauncherWrapper) Terminated

func (l LauncherWrapper) Terminated() <-chan struct{}

func (LauncherWrapper) Terminating

func (l LauncherWrapper) Terminating() <-chan struct{}