start

package
v0.75.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2024 License: AGPL-3.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ResetDatabaseAndNetworkHistory added in v0.71.0 

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 added in v0.63.0 

func (l *NodeCommand) Stop()

Stop is for graceful shutdown.

type SQLSubscribers added in v0.57.0 

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

func (*SQLSubscribers) CreateAllStores added in v0.57.0 

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

func (*SQLSubscribers) GetSQLSubscribers added in v0.57.0 

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

func (*SQLSubscribers) SetupSQLSubscribers added in v0.57.0 

func (s *SQLSubscribers) SetupSQLSubscribers()

func (*SQLSubscribers) SetupServices added in v0.57.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.