initialise

Documentation

Index

• Variables
• func DataNodeHasData(ctx context.Context, conf sqlstore.ConnectionConfig) (bool, error)
• func DataNodeIsEmpty(ctx context.Context, connConfig sqlstore.ConnectionConfig) (bool, error)
• func DatanodeFromDeHistory(parentCtx context.Context, cfg Config, log *logging.Logger, ...) (err error)
• func FetchHistoryBlocks(ctx context.Context, logInfo func(s string, args ...interface{}), ...) (int64, error)
• func GetDatanodeBlockSpan(ctx context.Context, connConfig sqlstore.ConnectionConfig) (from int64, to int64, err error)
• func GetDatanodeClientFromIPAndPort(ip string, port int) (v2.TradingDataServiceClient, *grpc.ClientConn, error)
• func GetMostRecentHistorySegmentFromPeer(ctx context.Context, ip string, datanodeGrpcAPIPort int) (*v2.HistorySegment, error)
• func GetMostRecentHistorySegmentFromPeers(ctx context.Context, peerAddresses []string, grpcAPIPorts []int) (*v2.HistorySegment, map[string]*v2.HistorySegment, error)
• func GetOldestHistoryBlockAndLastBlock(ctx context.Context, connConfig sqlstore.ConnectionConfig) (oldestHistoryBlock *entities.Block, lastBlock *entities.Block, err error)
• func HasVegaSchema(ctx context.Context, conf sqlstore.ConnectionConfig) (bool, error)
• func SelectRootSegment(peerToSegment map[string]*v2.HistorySegment) *v2.HistorySegment
• func VerifyChainID(chainID string, chainService *service.Chain) error
• type Config
  • func NewDefaultConfig() Config
• type FetchResult
  • func FromSegmentIndexEntry(s store.SegmentIndexEntry) FetchResult

Variables

var ErrChainNotFound = errors.New("no chain found")

Functions

func DataNodeHasData

func DataNodeHasData(ctx context.Context, conf sqlstore.ConnectionConfig) (bool, error)

func DataNodeIsEmpty

func DataNodeIsEmpty(ctx context.Context, connConfig sqlstore.ConnectionConfig) (bool, error)

func DatanodeFromDeHistory

func DatanodeFromDeHistory(parentCtx context.Context, cfg Config, log *logging.Logger,
	deHistoryService deHistoryService, grpcPorts []int,
) (err error)

func FetchHistoryBlocks

func FetchHistoryBlocks(ctx context.Context, logInfo func(s string, args ...interface{}), historySegmentID string,
	fetchHistory func(ctx context.Context, historySegmentID string) (FetchResult, error),
	numBlocksToFetch int64,
) (int64, error)

FetchHistoryBlocks will keep fetching history until numBlocksToFetch is reached or all history is retrieved.

func GetDatanodeBlockSpan

func GetDatanodeBlockSpan(ctx context.Context, connConfig sqlstore.ConnectionConfig) (from int64, to int64, err error)

func GetDatanodeClientFromIPAndPort

func GetDatanodeClientFromIPAndPort(ip string, port int) (v2.TradingDataServiceClient, *grpc.ClientConn, error)

func GetMostRecentHistorySegmentFromPeer

func GetMostRecentHistorySegmentFromPeer(ctx context.Context, ip string, datanodeGrpcAPIPort int) (*v2.HistorySegment, error)

func GetMostRecentHistorySegmentFromPeers

func GetMostRecentHistorySegmentFromPeers(ctx context.Context, peerAddresses []string,
	grpcAPIPorts []int,
) (*v2.HistorySegment, map[string]*v2.HistorySegment, error)

func GetOldestHistoryBlockAndLastBlock

func GetOldestHistoryBlockAndLastBlock(ctx context.Context, connConfig sqlstore.ConnectionConfig) (oldestHistoryBlock *entities.Block, lastBlock *entities.Block, err error)

func HasVegaSchema

func HasVegaSchema(ctx context.Context, conf sqlstore.ConnectionConfig) (bool, error)

func SelectRootSegment

func SelectRootSegment(peerToSegment map[string]*v2.HistorySegment) *v2.HistorySegment

TODO this needs some thought as to the best strategy to select the root segment to avoid spoofing.

func VerifyChainID

func VerifyChainID(chainID string, chainService *service.Chain) error

Types

type Config

type Config struct {
	ToSegment         string            `` /* 146-byte string literal not displayed */
	MinimumBlockCount int64             `long:"block-count" description:"the minimum number of blocks to fetch"`
	TimeOut           encoding.Duration `long:"timeout" description:"maximum time allowed to auto-initialise the node"`
	GrpcAPIPorts      []int             `long:"grpc-api-ports" description:"list of additional ports to check to for api connection when getting latest segment"`
}

func NewDefaultConfig

func NewDefaultConfig() Config

type FetchResult

type FetchResult struct {
	HeightFrom               int64
	HeightTo                 int64
	PreviousHistorySegmentID string
}

func FromSegmentIndexEntry

func FromSegmentIndexEntry(s store.SegmentIndexEntry) FetchResult