client

package
v0.0.11 Latest Latest
Warning

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

Go to latest
Published: Feb 4, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

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

func NewClient

func NewClient(log *zap.Logger, storeEng store.DataStore, ethConn EthereumConnector, ccs *contract.Contracts, smallestPossibleHeight, maxHeightsPerRequest uint64) *Client

func (*Client) GetAccounts

func (c *Client) GetAccounts(ctx context.Context, params structs.AccountParams) (accounts []structs.Account, err error)

func (*Client) GetContractEvents

func (c *Client) GetContractEvents(ctx context.Context, params structs.EventParams) (contractEvents []structs.ContractEvent, err error)

func (*Client) GetDelegationTimeline

func (c *Client) GetDelegationTimeline(ctx context.Context, params structs.DelegationParams) (delegations []structs.Delegation, err error)

func (*Client) GetDelegations

func (c *Client) GetDelegations(ctx context.Context, params structs.DelegationParams) (delegations []structs.Delegation, err error)

func (*Client) GetLatestData

func (c *Client) GetLatestData(ctx context.Context, taskID string, latest uint64) (latestBlock uint64, isRunning bool, err error)

func (*Client) GetNodes

func (c *Client) GetNodes(ctx context.Context, params structs.NodeParams) (nodes []structs.Node, err error)

func (*Client) GetSystemEvents

func (c *Client) GetSystemEvents(ctx context.Context, params structs.SystemEventParams) (systemEvents []structs.SystemEvent, err error)

func (*Client) GetTypesSummaryDelegations added in v0.0.4

func (c *Client) GetTypesSummaryDelegations(ctx context.Context, params structs.DelegationParams) (delegations []structs.DelegationSummary, err error)

func (*Client) GetValidatorStatistics

func (c *Client) GetValidatorStatistics(ctx context.Context, params structs.ValidatorStatisticsParams) (validatorStatistics []structs.ValidatorStatistics, err error)

func (*Client) GetValidatorStatisticsTimeline

func (c *Client) GetValidatorStatisticsTimeline(ctx context.Context, params structs.ValidatorStatisticsParams) (validatorStatistics []structs.ValidatorStatistics, err error)

func (*Client) GetValidators

func (c *Client) GetValidators(ctx context.Context, params structs.ValidatorParams) (validators []structs.Validator, err error)

func (*Client) ParseLogs

func (c *Client) ParseLogs(ctx context.Context, taskID string, from, to big.Int) error

type EthereumConnector

type EthereumConnector interface {
	ParseLogs(ctx context.Context, ccs *contract.Contracts, taskID string, from, to big.Int) error
	GetLatestBlockHeight(ctx context.Context) (uint64, error)
}

type PSig

type PSig struct {
	TaskID string
}

type Process

type Process struct {
	Started   time.Time
	Finished  bool
	EndHeight uint64
	Error     error
}

type Running

type Running struct {
	Processes map[PSig]Process
	// contains filtered or unexported fields
}

func NewRunning

func NewRunning() *Running

Directories

Path Synopsis
transport
webapi
Package webapi SKALE Indexer API An api for SKALE indexer to retrieve and fetch SKALE network information Terms Of Service: there are no TOS at this moment, use at your own risk we take no responsibility Schemes: http Host: localhost:8885 BasePath: / Version: 0.0.1 Consumes: - application/json Produces: - application/json swagger:meta
Package webapi SKALE Indexer API An api for SKALE indexer to retrieve and fetch SKALE network information Terms Of Service: there are no TOS at this moment, use at your own risk we take no responsibility Schemes: http Host: localhost:8885 BasePath: / Version: 0.0.1 Consumes: - application/json Produces: - application/json swagger:meta

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL