raft

package

v0.0.0-...-5e3b6f7 Latest Latest Go to latest Published: Dec 16, 2021 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/austingebauer/raft-kv-db

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func SetupServeMux(mux *http.ServeMux, s *Server)
type ApplyFunc
type HTTPPeer
type Peer
type Server
- func NewServer(id uint64, store io.ReadWriter, a ApplyFunc) *Server

Constants ¶

View Source

const (
	PeerSetConfigurationPath = "/raft/setconfiguration"
	PeerAppendEntriesPath    = "/raft/appendentries"
	PeerIDPath               = "/raft/id"
	PeerCommandPath          = "/raft/command"
	PeerRequestVotePath      = "/raft/requestvote"
)

Variables ¶

View Source

var (
	MinimumElectionTimeoutMS int32 = 250
)

Functions ¶

func SetupServeMux ¶

func SetupServeMux(mux *http.ServeMux, s *Server)

Types ¶

type ApplyFunc ¶

type ApplyFunc func(commitIndex uint64, cmd []byte) []byte

type HTTPPeer ¶

type HTTPPeer struct {
	RemoteID uint64
	URL      *url.URL
}

type Peer ¶

type Peer interface {
	// contains filtered or unexported methods
}

type Server ¶

type Server struct {
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(id uint64, store io.ReadWriter, a ApplyFunc) *Server

func (*Server) Command ¶

func (s *Server) Command(cmd []byte, response chan<- []byte) error

func (*Server) SetConfiguration ¶

func (s *Server) SetConfiguration(peers ...Peer) error

func (*Server) Start ¶

func (s *Server) Start()

func (*Server) Stop ¶

func (s *Server) Stop()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL