network

type BlockchainNetwork struct {
	Transactions   []chain.LocalTransaction //pending transactions
	CandidateBlock chan chain.Block         //pending block
	BlockSender    map[string]int           //the sender of the candidate block
	VerifiedBlock  chain.Block              //the verfied block
	Members        chain.MemberSet          //committee members
	Nodes          chain.PeerSet            //the registered nodes in the network
	Task           TaskInfo                 //the task published in the network
	StakeMap       map[int]int              //the stake map of nodes
	Vrf            consensus.VRF            //stake based random role selection

	VoteLock      sync.Mutex //control the voting process
	CommitteeLock sync.Mutex //control the committee process
	BlockLock     sync.Mutex //control the candidate block receiving process
	TxLock        sync.Mutex //control the tx receiving process

	CommitteeWait  chan bool
	CommitteeSetup chan bool
	CandidateWait  chan bool
	BlockReceived  chan bool
	NewBlock       chan bool
	NewRound       chan bool
	NewTask        bool
}

type Candidate struct {
	PendingBlock chain.Block
	Sender       int //the id number of the sender
}

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

type HandleFunc func(*bufio.ReadWriter, net.Addr)

type RegisterInfo struct {
	ID      int
	Address string
	Pk      vrf.PublicKey
}

type TaskInfo struct {
	TaskName      string
	Model         *python3.PyObject
	GlobalModel   string
	ModelSize     [][]int
	CompModelSize []int //the compressed model size
	PartNum       int   //the number of participants required in each training round
	Rank          int
	CurrentRound  int
	Beta          float64
	Slr           float64
	UnlabeledData *python3.PyObject
}