api

Documentation

Index

• func Run(p *persistence.Persistence, prv *ecdsa.PrivateKey, pubSub *p2p.PubSub, ...) error
• type ErrResp
  • func NewErrResp(err error) *ErrResp
• type HandleMessageReq
• type HandleMessageResp
• type QueryTaskReq
• type QueryTaskResp
• type StateLog

Functions

func Run

func Run(p *persistence.Persistence, prv *ecdsa.PrivateKey, pubSub *p2p.PubSub, aggregationAmount int, address string) error

this func will block caller

Types

type ErrResp

type ErrResp struct {
	Error string `json:"error,omitempty"`
}

func NewErrResp

func NewErrResp(err error) *ErrResp

type HandleMessageReq

type HandleMessageReq struct {
	ProjectID      uint64 `json:"projectID"                  binding:"required"`
	ProjectVersion string `json:"projectVersion"             binding:"required"`
	Data           string `json:"data"                       binding:"required"`
	Signature      string `json:"signature,omitempty"        binding:"required"`
}

type HandleMessageResp

type HandleMessageResp struct {
	TaskID string `json:"taskID"`
}

type QueryTaskReq

type QueryTaskReq struct {
	ProjectID uint64 `json:"projectID"                  binding:"required"`
	TaskID    string `json:"taskID"                     binding:"required"`
}

type QueryTaskResp

type QueryTaskResp struct {
	ProjectID uint64      `json:"projectID"`
	TaskID    string      `json:"taskID"`
	States    []*StateLog `json:"states"`
}

type StateLog

type StateLog struct {
	State    string    `json:"state"`
	Time     time.Time `json:"time"`
	Comment  string    `json:"comment,omitempty"`
	Tx       string    `json:"transaction_hash,omitempty"`
	ProverID string    `json:"prover_id,omitempty"`
}