()
| 1039 | } |
| 1040 | |
| 1041 | func (n *node) Snapshot() (*pb.Snapshot, error) { |
| 1042 | if n == nil || n.Store == nil { |
| 1043 | return nil, conn.ErrNoNode |
| 1044 | } |
| 1045 | snap, err := n.Store.Snapshot() |
| 1046 | if err != nil { |
| 1047 | return nil, err |
| 1048 | } |
| 1049 | res := &pb.Snapshot{} |
| 1050 | if err := proto.Unmarshal(snap.Data, res); err != nil { |
| 1051 | return nil, err |
| 1052 | } |
| 1053 | return res, nil |
| 1054 | } |
| 1055 | |
| 1056 | func (n *node) retrieveSnapshot(snap *pb.Snapshot) error { |
| 1057 | closer, err := n.startTask(opSnapshot) |
no outgoing calls
no test coverage detected