runner

Documentation

Index

• type BlockMapReducer
• type Context
  • func Run(client *rpc.Client, implementation BlockMapReducer) (*Context, error)
  • func (ctx *Context) Interrupt()
  • func (ctx *Context) Wait() error

Types

type BlockMapReducer

type BlockMapReducer interface {
	Initialise(client *rpc.Client) (acc interface{}, err error)
	BlockRange() (blockRangeFrom, blockRangeTo uint32)
	Map(client *rpc.Client, emit func(interface{}) error, block *rpc.Block) (err error)
	Reduce(client *rpc.Client, acc, value interface{}) (newAcc interface{}, err error)
	ProcessResults(acc interface{}, nextBlockToProcess uint32) (err error)
}

type Context

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

func Run

func Run(client *rpc.Client, implementation BlockMapReducer) (*Context, error)

func (*Context) Interrupt

func (ctx *Context) Interrupt()

func (*Context) Wait

func (ctx *Context) Wait() error