forked from tiglabs/raft
-
Notifications
You must be signed in to change notification settings - Fork 0
/
statemachine.go
37 lines (31 loc) · 935 Bytes
/
statemachine.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
package raft
import (
"github.com/tiglabs/raft/proto"
)
// The StateMachine interface is supplied by the application to persist/snapshot data of application.
type StateMachine interface {
Apply(command []byte, index uint64) (interface{}, error)
ApplyMemberChange(confChange *proto.ConfChange, index uint64) (interface{}, error)
Snapshot() (proto.Snapshot, error)
ApplySnapshot(peers []proto.Peer, iter proto.SnapIterator) error
HandleFatalEvent(err *FatalError)
HandleLeaderChange(leader uint64)
}
type SocketType byte
const (
HeartBeat SocketType = 0
Replicate SocketType = 1
)
func (t SocketType) String() string {
switch t {
case 0:
return "HeartBeat"
case 1:
return "Replicate"
}
return "unkown"
}
// The SocketResolver interface is supplied by the application to resolve NodeID to net.Addr addresses.
type SocketResolver interface {
NodeAddress(nodeID uint64, stype SocketType) (addr string, err error)
}