node_mindreader_stdin

Documentation

Index

• type App
  • func New(c *Config, modules *Modules, zlogger *zap.Logger) *App
  • func (a *App) IsReady() bool
  • func (a *App) OnReady(f func())
  • func (a *App) Run() error
• type Config
• type Modules

Types

type App

type App struct {
	*shutter.Shutter
	Config    *Config
	ReadyFunc func()
	// contains filtered or unexported fields
}

func New

func New(c *Config, modules *Modules, zlogger *zap.Logger) *App

func (*App) IsReady

func (a *App) IsReady() bool

func (*App) OnReady

func (a *App) OnReady(f func())

func (*App) Run

func (a *App) Run() error

type Config

type Config struct {
	GRPCAddr                     string
	ArchiveStoreURL              string
	MergeArchiveStoreURL         string
	OneblockSuffix               string
	BatchMode                    bool
	MergeThresholdBlockAge       time.Duration
	MindReadBlocksChanCapacity   int
	FailOnNonContinuousBlocks    bool
	StartBlockNum                uint64
	StopBlockNum                 uint64
	DiscardAfterStopBlock        bool
	WorkingDir                   string
	WaitUploadCompleteOnShutdown time.Duration
}

type Modules

type Modules struct {
	ConsoleReaderFactory       mindreader.ConsolerReaderFactory
	ConsoleReaderTransformer   mindreader.ConsoleReaderBlockTransformer
	MetricsAndReadinessManager *nodeManager.MetricsAndReadinessManager
	RegisterGRPCService        func(server *grpc.Server) error
	Tracker                    *bstream.Tracker
}