Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions src/raft/http/handler.cr
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
require "http/server/handler"
require "json"
require "../node"
require "../transport/tcp_transport"

module Raft
module HTTP
Expand Down
4 changes: 4 additions & 0 deletions src/raft/log.cr
Original file line number Diff line number Diff line change
@@ -1,3 +1,7 @@
require "./config"
require "./log_entry"
require "./log/segment"

module Raft
class Log(T)
getter last_index : UInt64 = 0_u64
Expand Down
2 changes: 2 additions & 0 deletions src/raft/log_entry.cr
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
require "./message"

module Raft
struct LogEntry(T)
getter term : UInt64
Expand Down
2 changes: 2 additions & 0 deletions src/raft/message.cr
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
require "./config"

module Raft
enum EntryType : UInt8
Normal = 0
Expand Down
1 change: 1 addition & 0 deletions src/raft/metrics.cr
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
require "sync/exclusive"
require "./config"

module Raft
class Metrics
Expand Down
8 changes: 8 additions & 0 deletions src/raft/node.cr
Original file line number Diff line number Diff line change
@@ -1,3 +1,11 @@
require "./config"
require "./message"
require "./peer"
require "./log_entry"
require "./log"
require "./state_machine"
require "./metrics"

module Raft
# Implements the Raft consensus protocol for a single peer in a single
# group. Generic over `T`, the application's command type.
Expand Down
2 changes: 2 additions & 0 deletions src/raft/peer.cr
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
require "./config"

module Raft
struct Peer
enum Role : UInt8
Expand Down
4 changes: 4 additions & 0 deletions src/raft/server.cr
Original file line number Diff line number Diff line change
@@ -1,4 +1,8 @@
require "sync/shared"
require "./config"
require "./message"
require "./node"
require "./state_machine"

module Raft
class Server(T)
Expand Down
3 changes: 3 additions & 0 deletions src/raft/transport.cr
Original file line number Diff line number Diff line change
@@ -1,3 +1,6 @@
require "./config"
require "./message"

module Raft
abstract class Transport
abstract def outbox : Channel({NodeID, Message})
Expand Down
2 changes: 2 additions & 0 deletions src/raft/transport/memory_transport.cr
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
require "sync/exclusive"
require "sync/shared"
require "../config"
require "../message"
require "../transport"

module Raft
# In-memory transport backed by IO pipes. Wire format is identical to
Expand Down
3 changes: 3 additions & 0 deletions src/raft/transport/tcp_transport.cr
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
require "socket"
require "sync/exclusive"
require "sync/shared"
require "../config"
require "../message"
require "../transport"

module Raft
class TCPTransport < Transport
Expand Down