auditor

Documentation

Index

• Constants
• func CheckSize(size int) bool
• func ParentHash(leftBytes []byte, rightBytes []byte) []byte
• func RequestReportMerkleRoot(baseUrl string, timeout uint64, taskId uint64, xwcAddr string, ...) (uint64, uint64, error)
• func RequestReportPathData(baseUrl string, timeout uint64, taskId uint64, xwcAddr string, ...) error
• func RequestServerTimestamp(baseUrl string, timeout uint64) (int64, error)
• func RequestTask(baseUrl string, timeout uint64, timestamp int64, xwcAddr string, ...) (uint64, error)
• type Auditor
  • func CreateNewAuditor(endpoint string, localDB *localstore.DB, signer crypto.Signer, ...) *Auditor
  • func (r *Auditor) Run()
• type TreeNode
  • func BuildBTreeFromRetrievalAddresses(retrievalAddresses [][]byte) (*TreeNode, error)
  • func (t *TreeNode) GetNodeHash() []byte
  • func (t *TreeNode) GetNodeHashHex() string
  • func (t *TreeNode) GetPathWayHashHex(pathway uint64) (string, [][]string, string)
  • func (t *TreeNode) GetRootRelatedHashHex() (string, []string)
• type TreeNodeValue

Constants

const (
	WAIT_SECONDS        = 5 * 60
	AUDITOR_RPC_TIMEOUT = 10
)

Functions

func CheckSize

func CheckSize(size int) bool

Check if the size value is 2^n

func ParentHash

func ParentHash(leftBytes []byte, rightBytes []byte) []byte

func RequestReportMerkleRoot

func RequestReportMerkleRoot(baseUrl string, timeout uint64, taskId uint64, xwcAddr string, xwcPubKey string, penguinNode string, signature string,
	pathData [][]string) (uint64, uint64, error)

func RequestReportPathData

func RequestReportPathData(baseUrl string, timeout uint64, taskId uint64, xwcAddr string, xwcPubKey string, penguinNode string, signature string,
	pathData [][]string, penguinData string) error

func RequestServerTimestamp

func RequestServerTimestamp(baseUrl string, timeout uint64) (int64, error)

func RequestTask

func RequestTask(baseUrl string, timeout uint64, timestamp int64, xwcAddr string, xwcPubKey string, penguinNode string, signature string) (uint64, error)

Types

type Auditor

type Auditor struct {

	//
	AuditEndpoint string
	// Local store db
	LocalDB *localstore.DB

	// Node address
	PenguinAddress string
	// Signer
	Signer crypto.Signer
	// Signer pubkey (hex)
	SignerPubKey string
	// Payer xwc address
	XwcAcctAddress string
	// contains filtered or unexported fields
}

func CreateNewAuditor

func CreateNewAuditor(endpoint string, localDB *localstore.DB, signer crypto.Signer, logger logging.Logger) *Auditor

func (*Auditor) Run

func (r *Auditor) Run()

type TreeNode

type TreeNode struct {
	PtrLeftSon  *TreeNode
	PtrRightSon *TreeNode
	Data        TreeNodeValue
}

func BuildBTreeFromRetrievalAddresses

func BuildBTreeFromRetrievalAddresses(retrievalAddresses [][]byte) (*TreeNode, error)

func (*TreeNode) GetNodeHash

func (t *TreeNode) GetNodeHash() []byte

func (*TreeNode) GetNodeHashHex

func (t *TreeNode) GetNodeHashHex() string

func (*TreeNode) GetPathWayHashHex

func (t *TreeNode) GetPathWayHashHex(pathway uint64) (string, [][]string, string)

func (*TreeNode) GetRootRelatedHashHex

func (t *TreeNode) GetRootRelatedHashHex() (string, []string)

type TreeNodeValue

type TreeNodeValue *[]byte