datanode

Documentation

Index

• Constants
• Variables
• type DataNodeClient
  • func NewDataNodeClient(apiURL string) *DataNodeClient
  • func (c *DataNodeClient) GetNetworkHistorySegments(fromBlock, toBlock int64) ([]*NetworkHistorySegment, error)
  • func (c *DataNodeClient) GetStatistics(ctx context.Context) (*entities.Statistics, error)
  • func (c *DataNodeClient) GetStatisticsWithHeaders(ctx context.Context, wantedHeaders []string) (*entities.Statistics, map[string]string, error)
  • func (c *DataNodeClient) IsHealthy(ctx context.Context) (bool, error)
• type NetworkHistorySegment

Constants

const DataNodeHeightHeader = "x-block-height"

Variables

var (
	ErrHttpCallError            = errors.New("error during http call")
	ErrMissingOrInvalidResponse = errors.New("missing some information from the data-node response")
	ErrTimeGapTooBig            = errors.New("time gap between core and data-node is too big")
	ErrBlocksGapTooBig          = errors.New("blocks gap between core and data-node is too big")
)

Types

type DataNodeClient

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

func NewDataNodeClient

func NewDataNodeClient(apiURL string) *DataNodeClient

func (*DataNodeClient) GetNetworkHistorySegments

func (c *DataNodeClient) GetNetworkHistorySegments(fromBlock, toBlock int64) ([]*NetworkHistorySegment, error)

func (*DataNodeClient) GetStatistics

func (c *DataNodeClient) GetStatistics(ctx context.Context) (*entities.Statistics, error)

func (*DataNodeClient) GetStatisticsWithHeaders

func (c *DataNodeClient) GetStatisticsWithHeaders(ctx context.Context, wantedHeaders []string) (*entities.Statistics, map[string]string, error)

func (*DataNodeClient) IsHealthy

func (c *DataNodeClient) IsHealthy(ctx context.Context) (bool, error)

type NetworkHistorySegment

type NetworkHistorySegment struct {
	Height    int64  `db:"height"`
	SegmentId string `db:"segment_id"`
	DataNode  string `db:"data_node"`
}