start

Documentation

Index

• func ResetDatabaseAndNetworkHistory(ctx context.Context, log *logging.Logger, vegaPaths paths.Paths, ...) error
• type NodeCommand
  • func (l *NodeCommand) Run(ctx context.Context, cfgwatchr *config.Watcher, vegaPaths paths.Paths, ...) error
  • func (l *NodeCommand) Stop()
• type SQLSubscribers
  • func (s *SQLSubscribers) CreateAllStores(ctx context.Context, Log *logging.Logger, ...)
  • func (s *SQLSubscribers) GetSQLSubscribers() []broker.SQLBrokerSubscriber
  • func (s *SQLSubscribers) SetupSQLSubscribers()
  • func (s *SQLSubscribers) SetupServices(ctx context.Context, log *logging.Logger, cfg service.Config, ...) error

Functions

func ResetDatabaseAndNetworkHistory

func ResetDatabaseAndNetworkHistory(ctx context.Context, log *logging.Logger, vegaPaths paths.Paths, connConfig sqlstore.ConnectionConfig) error

Types

type NodeCommand

type NodeCommand struct {
	SQLSubscribers

	Log *logging.Logger

	Version     string
	VersionHash string
	// contains filtered or unexported fields
}

NodeCommand use to implement 'node' command.

func (*NodeCommand) Run

func (l *NodeCommand) Run(ctx context.Context, cfgwatchr *config.Watcher, vegaPaths paths.Paths, args []string) error

func (*NodeCommand) Stop

func (l *NodeCommand) Stop()

Stop is for graceful shutdown.

type SQLSubscribers

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

func (*SQLSubscribers) CreateAllStores

func (s *SQLSubscribers) CreateAllStores(ctx context.Context, Log *logging.Logger, transactionalConnectionSource *sqlstore.ConnectionSource,
	candleV2Config candlesv2.CandleStoreConfig,
)

func (*SQLSubscribers) GetSQLSubscribers

func (s *SQLSubscribers) GetSQLSubscribers() []broker.SQLBrokerSubscriber

func (*SQLSubscribers) SetupSQLSubscribers

func (s *SQLSubscribers) SetupSQLSubscribers()

func (*SQLSubscribers) SetupServices

func (s *SQLSubscribers) SetupServices(ctx context.Context, log *logging.Logger, cfg service.Config, candlesConfig candlesv2.Config) error