dapi

Documentation

Index

• Constants
• func GetDat(d *godave.Dave, work []byte) (*godave.Dat, error)
• func MakeCans(d *godave.Dave, difficulty int, mch <-chan *dave.M) <-chan *dave.M
• func PrepChunks(chunks <-chan []byte, difficulty int) <-chan *dave.M
• func Read(r io.Reader, size int) <-chan []byte
• func SendDats(d *godave.Dave, mch <-chan *dave.M) <-chan *dave.M
• func SendM(d *godave.Dave, m *dave.M) error
• func SendShaGet(d *godave.Dave, work []byte) error
• func WaitForFirstDat(d *godave.Dave, w io.Writer)
• func Walk(d *godave.Dave, work []byte) ([]*can.Can, []*godave.Dat, error)

Constants

const NDAT = 38

const SIZE = 1234

Functions

func GetDat

func GetDat(d *godave.Dave, work []byte) (*godave.Dat, error)

func MakeCans

func MakeCans(d *godave.Dave, difficulty int, mch <-chan *dave.M) <-chan *dave.M

func PrepChunks

func PrepChunks(chunks <-chan []byte, difficulty int) <-chan *dave.M

func Read

func Read(r io.Reader, size int) <-chan []byte

func SendDats

func SendDats(d *godave.Dave, mch <-chan *dave.M) <-chan *dave.M

func SendM

func SendM(d *godave.Dave, m *dave.M) error

SendM sends message on dave's send chan with timeout.

func SendShaGet

func SendShaGet(d *godave.Dave, work []byte) error

Sends a randomised DAT message to a random peer. The work is invalid, but the hash correct.

func WaitForFirstDat

func WaitForFirstDat(d *godave.Dave, w io.Writer)

WaitForFirstDat logs the peer collection process, until we receive a DAT, expected after godave.SHARE_DELAY.

func Walk

func Walk(d *godave.Dave, work []byte) ([]*can.Can, []*godave.Dat, error)