pbft

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

type ApplyMsg struct {
	Index   int
	Content interface{}
}

type BftCommittee struct {
	Blocksize      int `yaml:"block_size"` // Blocksize specifies the number of transactions per block
	BlockFrequency int `yaml:"block_frequency"`
	Lambda         int `yaml:"lambda"`
	WaitTimeout    int `yaml:"wait_timeout"`
	Tbft           int `yaml:"tbft"`
	Th             int `yaml:"th"`
	ActualDelta    int `yaml:"actual_delta"`
	Delta          int `yaml:"delta"`
	Alpha          int `yaml:"alpha"`
	Csize          int `yaml:"csize"`
}

type Config struct {
	Tunables
	Logistics
	Network
}

type DailyBFTNode interface {
	ProxyProcessPrePrepare(arg ProxyProcessPrePrepareArg, reply *ProxyProcessPrePrepareReply) error
	ProxyProcessPrepare(arg ProxyProcessPrepareArg, reply *ProxyProcessPrepareReply) error
	ProxyProcessCommit(arg ProxyProcessCommitArg, reply *ProxyProcessCommitReply) error
	ProxyProcessViewChange(arg ProxyProcessViewChangeArg, reply *ProxyProcessViewChangeReply) error
	ProxyProcessNewView(arg ProxyProcessNewViewArg, reply *ProxyProcessNewViewReply) error
	ProxyProcessCheckpoint(arg ProxyProcessCheckpointArg, reply *ProxyProcessCheckpointReply) error

	NewClientRequest(req Request, clientID int)
	// contains filtered or unexported methods
}

type DigType string

type General struct {
	MaxFail         int `yaml:"max_fail"`
	BasePort        int `yaml:"rpc_base_port"`
	OutputThreshold int `yaml:"output_threshold"`
	MaxLogSize      int `yaml:"max_log_size"`
	GrpcBasePort    int `yaml:"grpc_base_port"`
	RequestTimeout  int `yaml:"request_timeout"`
}

type Log struct {
}

type Logistics struct {
	LedgerLoc string
	LD        string
	ServerLog string
	ClientLog string
	KD        string // key directory where pub/priva ECDSA keys are stored
}

type MsgSignature struct {
	R *big.Int
	S *big.Int
}

type MsgType string

type Network struct {
	N         int      // number of nodes to be launchedt
	IPList    []string // stores list of IP addresses belonging to BFT nodes
	Ports     []int    // stores list of Ports belonging to BFT nodes
	GrpcPorts []int    // stores list of ports serving grpc requests
	NumQuest  int      // NumQuest is the number of requests sent from client
	NumKeys   int      // NumKeys is the count of IP addresses (BFT nodes) participating
	HostsFile string   // contains network addresses for server/client/peers
}

type Node struct {
	ListenReady chan bool
	SetupReady  chan bool

	EcdsaKey *ecdsa.PrivateKey

	ID int
	N  int

	Primary int

	KeyDict map[int]keyItem
	// contains filtered or unexported fields
}

type ProxyProcessCheckpointArg struct {
	Req      Request
	ClientID int
}

type ProxyProcessCheckpointReply struct {
}

type ProxyProcessCommitArg struct {
	Req Request
}

type ProxyProcessCommitReply struct {
}

type ProxyProcessNewViewArg struct {
	Req      Request
	ClientID int
}

type ProxyProcessNewViewReply struct {
}

type ProxyProcessPrePrepareArg struct {
	Req      Request
	ClientID int
}

type ProxyProcessPrePrepareReply struct {
}

type ProxyProcessPrepareArg struct {
	Req      Request
	ClientID int
}

type ProxyProcessPrepareReply struct {
}

type ProxyProcessViewChangeArg struct {
	Req  Request
	From int
}

type ProxyProcessViewChangeReply struct {
}

type Request struct {
	Inner RequestInner
	Dig   DigType
	Sig   MsgSignature
}

type RequestInner struct {
	ID        int
	Seq       int
	View      int
	Reqtype   int //or int?
	Msg       MsgType
	Block     *pb.PbftBlock
	Timestamp int64
}

type Server struct {
	IP   string
	Port int
	Nd   *Node
	Cfg  *Config
	// contains filtered or unexported fields
}

type Slowchain struct {
	Csize int `yaml:"csize"` // Snailchain's chainsize
}

type Testbed struct {
	Total            int  `yaml:"total"`
	ClientID         int  `yaml:"client_id"`
	InitServerID     int  `yaml:"server_id_init"`
	ThreadingEnabled bool `yaml:"threading_enabled"`
	MaxRetries       int  `yaml:"max_retries"`
	MaxRequests      int  `yaml:"max_requests"`
	BatchSize        int  `yaml:"batch_size"`
}

type Tunables struct {
	// struct tags, to add metadata to a struct's fields
	// testbed config
	Testbed      `yaml:"testbed"`
	Slowchain    `yaml:"slowchain"`
	General      `yaml:"general"`
	BftCommittee `yaml:"bft_committee"`
}

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