client

Documentation

Index

• type Client
  • func NewClient(log *zap.Logger, storeEng store.DataStore, ethConn EthereumConnector, ...) *Client
  • func (c *Client) GetAccounts(ctx context.Context, params structs.AccountParams) (accounts []structs.Account, err error)
  • func (c *Client) GetContractEvents(ctx context.Context, params structs.EventParams) (contractEvents []structs.ContractEvent, err error)
  • func (c *Client) GetDelegationTimeline(ctx context.Context, params structs.DelegationParams) (delegations []structs.Delegation, err error)
  • func (c *Client) GetDelegations(ctx context.Context, params structs.DelegationParams) (delegations []structs.Delegation, err error)
  • func (c *Client) GetLatestData(ctx context.Context, taskID string, latest uint64) (latestBlock uint64, isRunning bool, err error)
  • func (c *Client) GetNodes(ctx context.Context, params structs.NodeParams) (nodes []structs.Node, err error)
  • func (c *Client) GetSystemEvents(ctx context.Context, params structs.SystemEventParams) (systemEvents []structs.SystemEvent, err error)
  • func (c *Client) GetTypesSummaryDelegations(ctx context.Context, params structs.DelegationParams) (delegations []structs.DelegationSummary, err error)
  • func (c *Client) GetValidatorStatistics(ctx context.Context, params structs.ValidatorStatisticsParams) (validatorStatistics []structs.ValidatorStatistics, err error)
  • func (c *Client) GetValidatorStatisticsTimeline(ctx context.Context, params structs.ValidatorStatisticsParams) (validatorStatistics []structs.ValidatorStatistics, err error)
  • func (c *Client) GetValidators(ctx context.Context, params structs.ValidatorParams) (validators []structs.Validator, err error)
  • func (c *Client) ParseLogs(ctx context.Context, taskID string, from, to big.Int) error
• type EthereumConnector
• type PSig
• type Process
• type Running
  • func NewRunning() *Running

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

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