This repository has been archived by the owner on Feb 29, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 11
/
config.go
72 lines (57 loc) · 1.99 KB
/
config.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
package bdls
import (
"crypto/ecdsa"
"time"
)
const (
// ConfigMinimumParticipants is the minimum number of participant allow in consensus protocol
ConfigMinimumParticipants = 4
)
// Config is to config the parameters of BDLS consensus protocol
type Config struct {
// the starting time point for consensus
Epoch time.Time
// CurrentHeight
CurrentHeight uint64
// PrivateKey
PrivateKey *ecdsa.PrivateKey
// Consensus Group
Participants []Identity
// EnableCommitUnicast sets to true to enable <commit> message to be delivered via unicast
// if not(by default), <commit> message will be broadcasted
EnableCommitUnicast bool
// StateCompare is a function from user to compare states,
// The result will be 0 if a==b, -1 if a < b, and +1 if a > b.
// Usually this will lead to block header comparsion in blockchain, or replication log in database,
// users should check fields in block header to make comparison.
StateCompare func(a State, b State) int
// StateValidate is a function from user to validate the integrity of
// state data.
StateValidate func(State) bool
// MessageValidator is an external validator to be called when a message inputs into ReceiveMessage
MessageValidator func(c *Consensus, m *Message, signed *SignedProto) bool
// MessageOutCallback will be called if not nil before a message send out
MessageOutCallback func(m *Message, signed *SignedProto)
// Identity derviation from ecdsa.PublicKey
// (optional). Default to DefaultPubKeyToIdentity
PubKeyToIdentity func(pubkey *ecdsa.PublicKey) (ret Identity)
}
// VerifyConfig verifies the integrity of this config when creating new consensus object
func VerifyConfig(c *Config) error {
if c.Epoch.IsZero() {
return ErrConfigEpoch
}
if c.StateCompare == nil {
return ErrConfigStateCompare
}
if c.StateValidate == nil {
return ErrConfigStateValidate
}
if c.PrivateKey == nil {
return ErrConfigPrivateKey
}
if len(c.Participants) < ConfigMinimumParticipants {
return ErrConfigParticipants
}
return nil
}