-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
4 changed files
with
612 additions
and
35 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,107 @@ | ||
| package log | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| "github.com/hashicorp/raft" | ||
| raftboltdb "github.com/rqlite/raft-boltdb/v2" | ||
| "go.etcd.io/bbolt" | ||
| ) | ||
|
|
||
| const ( | ||
| appliedIndex = "applied_index" | ||
| ) | ||
|
|
||
| // Log is an object that can return information about the Raft log. | ||
| type Log struct { | ||
| *raftboltdb.BoltStore | ||
| } | ||
|
|
||
| // New returns an instantiated Log object that provides access to the Raft log | ||
| // stored in a BoltDB database. It takes a path to the database file and a | ||
| // boolean flag to enable/disable the freelist sync. If the flag is set to true, | ||
| // the freelist will not be synced to disk, which can improve write performance | ||
| // but may increase the risk of data loss in the event of a crash or power loss. | ||
| // Returns an error if the BoltDB store cannot be created. | ||
| func New(path string, noFreelistSync bool) (*Log, error) { | ||
| bs, err := raftboltdb.New(raftboltdb.Options{ | ||
| BoltOptions: &bbolt.Options{ | ||
| NoFreelistSync: noFreelistSync, | ||
| }, | ||
| Path: path, | ||
| }) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("new bbolt store: %s", err) | ||
| } | ||
| return &Log{bs}, nil | ||
| } | ||
|
|
||
| // Indexes returns the first and last indexes. | ||
| func (l *Log) Indexes() (uint64, uint64, error) { | ||
| fi, err := l.FirstIndex() | ||
| if err != nil { | ||
| return 0, 0, fmt.Errorf("failed to get first index: %s", err) | ||
| } | ||
| li, err := l.LastIndex() | ||
| if err != nil { | ||
| return 0, 0, fmt.Errorf("failed to get last index: %s", err) | ||
| } | ||
| return fi, li, nil | ||
| } | ||
|
|
||
| // LastCommandIndex returns the index of the last Command | ||
| // log entry written to the Raft log. Returns an index of | ||
| // zero if no such log exists. | ||
| func (l *Log) LastCommandIndex(fi, li uint64) (uint64, error) { | ||
| // Check for empty log. According to the interface definition, if | ||
| // the first index is zero, or the last, the log is empty. | ||
| if fi == 0 || li == 0 { | ||
| return 0, nil | ||
| } | ||
|
|
||
| var rl raft.Log | ||
| for i := li; i >= fi; i-- { | ||
| if err := l.GetLog(i, &rl); err != nil { | ||
| return 0, fmt.Errorf("failed to get log at index %d: %s", i, err) | ||
| } | ||
| if rl.Type == raft.LogCommand { | ||
| return i, nil | ||
| } | ||
| } | ||
| return 0, nil | ||
| } | ||
|
|
||
| // HasCommand returns whether the Raft log contains any Command log entries. | ||
| func (l *Log) HasCommand() (bool, error) { | ||
| fi, li, err := l.Indexes() | ||
| if err != nil { | ||
| return false, err | ||
| } | ||
| if fi == 0 || li == 0 { | ||
| return false, nil | ||
| } | ||
| i, err := l.LastCommandIndex(fi, li) | ||
| if err != nil { | ||
| return false, err | ||
| } | ||
| return i != 0, nil | ||
| } | ||
|
|
||
| // SetAppliedIndex sets the AppliedIndex value. | ||
| func (l *Log) SetAppliedIndex(index uint64) error { | ||
| return l.SetUint64([]byte(appliedIndex), index) | ||
| } | ||
|
|
||
| // GetAppliedIndex returns the AppliedIndex value. | ||
| func (l *Log) GetAppliedIndex() (uint64, error) { | ||
| i, err := l.GetUint64([]byte(appliedIndex)) | ||
| if err != nil { | ||
| return 0, nil | ||
| } | ||
| return i, nil | ||
| } | ||
|
|
||
| // Stats returns stats about the BBoltDB database. | ||
| func (l *Log) Stats() bbolt.Stats { | ||
| return l.BoltStore.Stats() | ||
| } |
Oops, something went wrong.