engine

Documentation

Index

• Variables
• type Engine
  • func NewEngine(raftDir, nodeId, raftAddr, grpcAddr string, raftBootstrap bool) (*Engine, error)
  • func (engine *Engine) Close()
• type Server

Variables

var (
	ErrNotReadyForConsistentReads = errors.New("Not ready to serve consistent reads")
	ErrNoLeader                   = errors.New("No cluster leader")
)

Types

type Engine

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

func NewEngine

func NewEngine(raftDir, nodeId, raftAddr, grpcAddr string, raftBootstrap bool) (*Engine, error)

func (*Engine) Close

func (engine *Engine) Close()

type Server

type Server struct {
	ID       string `json:"id,omitempty"`
	Addr     string `json:"addr,omitempty"`
	Suffrage string `json:"suffrage,omitempty"`
}