client

Documentation

Index

• Variables
• func InitMetrics()
• type Client
  • func NewClient(logger *zap.Logger, sapi SearchApi) *Client
  • func (hc *Client) GetAccountBalance(ctx context.Context, nv NetworkVersion, start, end time.Time, account string) (balances []shared.BalanceSummary, err error)
  • func (hc *Client) GetRewardAPR(ctx context.Context, nv NetworkVersion, start, end time.Time, account string, ...) (aprs []shared.RewardAPRSummary, err error)
  • func (hc *Client) GetRewards(ctx context.Context, nv NetworkVersion, start, end time.Time, account string, ...) ([]shared.RewardSummary, error)
  • func (hc *Client) LatestData(ctx context.Context, ldr shared.LatestDataRequest) (ldResp shared.LatestDataResponse, er error)
  • func (hc *Client) LinkSender(sender TaskSender)
  • func (hc *Client) SyncData(ctx context.Context, ldr shared.SyncDataRequest) (ldResp shared.SyncDataResponse, er error)
• type ClientContractor
• type ControllContractor
• type NetworkVersion
• type PSig
• type ProcessLatestData
• type ProcessSyncData
• type Running
  • func NewRunning() *Running
• type SearchApi
• type TaskSender

Variables

var ErrIntegrityCheckFailed = errors.New("integrity check failed")

var ErrNotAvailable = errors.New("call unavailable")

var SelfCheck = true

SelfCheck Flag describing should manager check anyway the latest version for network it has

Functions

func InitMetrics

func InitMetrics()

Types

type Client

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

func NewClient

func NewClient(logger *zap.Logger, sapi SearchApi) *Client

func (*Client) GetAccountBalance

func (hc *Client) GetAccountBalance(ctx context.Context, nv NetworkVersion, start, end time.Time, account string) (balances []shared.BalanceSummary, err error)

GetAccountBalance calculates balance summaries for 24h segments for given time range

func (*Client) GetRewardAPR

func (hc *Client) GetRewardAPR(ctx context.Context, nv NetworkVersion, start, end time.Time, account string, validators []string) (aprs []shared.RewardAPRSummary, err error)

GetRewardApr calculates reward annual percentage rate summaries for 24h segments for given time range

func (*Client) GetRewards

func (hc *Client) GetRewards(ctx context.Context, nv NetworkVersion, start, end time.Time, account string, validators []string) ([]shared.RewardSummary, error)

GetRewards calculates reward summaries for 24h segments for given time range

func (*Client) LatestData

func (hc *Client) LatestData(ctx context.Context, ldr shared.LatestDataRequest) (ldResp shared.LatestDataResponse, er error)

func (*Client) LinkSender

func (hc *Client) LinkSender(sender TaskSender)

func (*Client) SyncData

func (hc *Client) SyncData(ctx context.Context, ldr shared.SyncDataRequest) (ldResp shared.SyncDataResponse, er error)

type ClientContractor

type ClientContractor interface {
	//	SchedulerContractor
	ControllContractor

	GetRewards(ctx context.Context, nv NetworkVersion, start, end time.Time, account string, validators []string) ([]shared.RewardSummary, error)
	GetAccountBalance(ctx context.Context, nv NetworkVersion, start, end time.Time, address string) (balances []shared.BalanceSummary, err error)
	GetRewardAPR(ctx context.Context, nv NetworkVersion, start, end time.Time, address string, validators []string) (aprs []shared.RewardAPRSummary, err error)
}

ClientContractor a format agnostic

type ControllContractor

type ControllContractor interface {
	LatestData(ctx context.Context, ldr shared.LatestDataRequest) (ldResp shared.LatestDataResponse, er error)
	SyncData(ctx context.Context, ldr shared.SyncDataRequest) (ldResp shared.SyncDataResponse, er error)
}

type NetworkVersion

type NetworkVersion struct {
	Network string
	ChainID string
	Version string
}

type PSig

type PSig struct {
	TaskID  string
	Network string
	ChainID string
	Version string
}

type ProcessLatestData

type ProcessLatestData struct {
	Started   time.Time
	Finished  bool
	EndHeight uint64
	Error     error
	Resp      shared.LatestDataResponse
	Retries   uint64
}

type ProcessSyncData

type ProcessSyncData struct {
	Started   time.Time
	Finished  bool
	EndHeight uint64
	Error     error
	Resp      shared.SyncDataResponse
	Retries   uint64
}

type Running

type Running struct {
	ProcessesSyncData   map[PSig]ProcessSyncData
	ProcessesLatestData map[PSig]ProcessLatestData
	// contains filtered or unexported fields
}

func NewRunning

func NewRunning() *Running

type SearchApi

type SearchApi interface {
	GetBlockForTime(ctx context.Context, blx shared.BlockWithMeta, time time.Time) (b shared.Block, ok bool, err error)
	GetTransactions(ctx context.Context, tsearch shared.TransactionSearchInternal) ([]shared.Transaction, error)
}

type TaskSender

type TaskSender interface {
	Send([]structs.TaskRequest) (*structs.Await, error)
}