pbft

type Commit struct {
	Sig    []byte `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	View   int32  `protobuf:"varint,2,opt,name=view,proto3" json:"view,omitempty"`
	Seq    int64  `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Digest []byte `protobuf:"bytes,4,opt,name=digest,proto3" json:"digest,omitempty"`
	Node   string `protobuf:"bytes,5,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

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

type NodeAPI interface {
	HandleRequest(msgB []byte) error
	// HandlePrePrepare parses msgPPB as preprepare & msgReqB as request
	HandlePrePrepare(msgPPB []byte, msgReqB []byte) error
	HandlePrepare(msgB []byte) error
	HandleCommit(msgB []byte) error
}

type NodeCommunicator interface {
	Unicast(msgB []byte, toNode string, msgType msgType) error
	// Broadcast should not sends the msg to itself, as that has been done in this library.
	Broadcast(msgB []byte, fromNode string, msgType msgType) error
	// BroadcastWithLarge is similar to [Broadcast], but it sends a small msg msgB together with a large msg msgLB, e.g., a preprepare with a request.
	// If you do not need the optimization, you can combine the two msgs and send them in one time.
	BroadcastWithLarge(msgB []byte, msgLB []byte, fromNode string, msgType msgType) error
	// Return can only send reply msg so no msgType is required
	Return(msgB []byte, toUser string) error
}

type NodeParams struct {
	ID string
	// N is total node num
	// TODO: Allow not 3f + 1
	N int
	// PKs should include the node's own pubkey
	PKs map[string][]byte
	SK  []byte
}

type NodePrimaryGetter interface {
	Get(view int) (primary string, err error)
}

type NodeStateMachine interface {
	// Transform does computation, so it may be slow
	Transform(op []byte) (result []byte)
}

type NodeStorage interface {
	Put(key string, val []byte) error
	// Get returns nil if not found
	Get(key string) (val []byte, err error)
}

type NodeUserPKGetter interface {
	Get(user string) (pk []byte, err error)
}

type PrePrepare struct {
	Sig    []byte `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	View   int32  `protobuf:"varint,2,opt,name=view,proto3" json:"view,omitempty"`
	Seq    int64  `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Digest []byte `protobuf:"bytes,4,opt,name=digest,proto3" json:"digest,omitempty"`
	// contains filtered or unexported fields
}

type Prepare struct {
	Sig    []byte `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	View   int32  `protobuf:"varint,2,opt,name=view,proto3" json:"view,omitempty"`
	Seq    int64  `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Digest []byte `protobuf:"bytes,4,opt,name=digest,proto3" json:"digest,omitempty"`
	Node   string `protobuf:"bytes,5,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

type Reply struct {
	Sig       []byte `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	View      int32  `protobuf:"varint,2,opt,name=view,proto3" json:"view,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	User      string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Node      string `protobuf:"bytes,5,opt,name=node,proto3" json:"node,omitempty"`
	// result may be large, so Reply may be large too
	Result []byte `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type Request struct {
	Sig []byte `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	// op may be large, so Request may be large too
	Op        []byte `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	User      string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}