chart

Documentation

Index

• type Client
  • func New(pooldbClient, tsdbClient *dbcl.Client, redisClient *redis.Client) *Client
  • func (c *Client) CollectBlocks(node types.MiningNode) error
  • func (c *Client) FetchBlockIntervals(chain string) ([]time.Time, error)
  • func (c *Client) FetchEarningIntervals(chain string) ([]time.Time, error)
  • func (c *Client) FetchShareIntervals(chain string) ([]string, error)
  • func (c *Client) ProcessBlocks(timestamp time.Time, node types.MiningNode) error
  • func (c *Client) ProcessEarnings(timestamp time.Time, node types.MiningNode) error
  • func (c *Client) ProcessPrices(chain string) error
  • func (c *Client) ProcessShares(chain, interval string, node types.MiningNode) error

Types

type Client

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

func New

func New(pooldbClient, tsdbClient *dbcl.Client, redisClient *redis.Client) *Client

func (*Client) CollectBlocks

func (c *Client) CollectBlocks(node types.MiningNode) error

func (*Client) FetchBlockIntervals

func (c *Client) FetchBlockIntervals(chain string) ([]time.Time, error)

func (*Client) FetchEarningIntervals

func (c *Client) FetchEarningIntervals(chain string) ([]time.Time, error)

func (*Client) FetchShareIntervals

func (c *Client) FetchShareIntervals(chain string) ([]string, error)

func (*Client) ProcessBlocks

func (c *Client) ProcessBlocks(timestamp time.Time, node types.MiningNode) error

func (*Client) ProcessEarnings

func (c *Client) ProcessEarnings(timestamp time.Time, node types.MiningNode) error

func (*Client) ProcessPrices

func (c *Client) ProcessPrices(chain string) error

func (*Client) ProcessShares

func (c *Client) ProcessShares(chain, interval string, node types.MiningNode) error