chainkit

func (*Chainkit) AssignmentHandler ¶

func (c *Chainkit) AssignmentHandler(assignmentResult nodeSchema.AssignmentResult)

func (*Chainkit) Close ¶

func (c *Chainkit) Close()

func (*Chainkit) DownloadByPid ¶

func (c *Chainkit) DownloadByPid(pid string, beginNonce, endNonce int64) (results []*schema.DownloadResult, err error)

Download all transactions of a process, from specified Nonce to latest transaction

func (*Chainkit) DownloadByTxid ¶

func (c *Chainkit) DownloadByTxid(txid string) (*goarSchema.BundleItem, error)

Download a transaction

func (*Chainkit) Query ¶

func (c *Chainkit) Query(query string) ([]byte, error)

Execute a GraphQL query

func (*Chainkit) Run ¶

func (c *Chainkit) Run()

func (*Chainkit) Upload ¶

func (c *Chainkit) Upload(tx goarSchema.BundleItem) error

Upload a BundleItem transaction. This function doesn't actually upload the transaction, but adds it to the upload queue and waits for batch processing before uploading