corereader

Documentation

Index

• type CoreReader
  • func (cr *CoreReader) CountBlocks() (int64, error)
  • func (cr *CoreReader) FetchBlockJsonBytes(height int64) ([]byte, error)
• type Pool
  • func NewPool(poolSize int, useSecondClient bool) *Pool
  • func (p *Pool) CountBlocks() (int64, error)
  • func (p *Pool) FetchBlockJsonBytes(height int64) ([]byte, error)
  • func (pool *Pool) Flush()
• type Task
  • func NewTask(height int64, completionChan *chan *Task) *Task

Types

type CoreReader

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

func (*CoreReader) CountBlocks

func (cr *CoreReader) CountBlocks() (int64, error)

func (*CoreReader) FetchBlockJsonBytes

func (cr *CoreReader) FetchBlockJsonBytes(height int64) ([]byte, error)

type Pool

type Pool struct {
	InChan chan *Task
	// contains filtered or unexported fields
}

func NewPool

func NewPool(poolSize int, useSecondClient bool) *Pool

func (*Pool) CountBlocks

func (p *Pool) CountBlocks() (int64, error)

func (*Pool) FetchBlockJsonBytes

func (p *Pool) FetchBlockJsonBytes(height int64) ([]byte, error)

func (*Pool) Flush

func (pool *Pool) Flush()

type Task

type Task struct {
	BlockHeight    int64
	ResultBytes    []byte
	ResultErr      error
	CompletionChan *chan *Task
}

func NewTask

func NewTask(height int64, completionChan *chan *Task) *Task