raft

Documentation

Index

• func SetDebug(w io.Writer)
• type Command
• type Config
• type Op
• type Raft
  • func NewRaft(c *Config) (r *Raft, err error)
  • func (r *Raft) Barrier() error
  • func (r *Raft) Config() raft.Configuration
  • func (r *Raft) Delete(key string) error
  • func (r *Raft) Get(key string) (string, error)
  • func (r *Raft) IsLeader() bool
  • func (r *Raft) Join(id, addr string) error
  • func (r *Raft) LocalID() string
  • func (r *Raft) Set(key, value string) error
• type RaftLayer
  • func NewRaftLayer(addr net.Addr) *RaftLayer
  • func (l *RaftLayer) Accept() (net.Conn, error)
  • func (l *RaftLayer) Addr() net.Addr
  • func (l *RaftLayer) Close() error
  • func (l *RaftLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)
  • func (l *RaftLayer) Handoff(c net.Conn) error
  • func (l *RaftLayer) Type() rpc.RPCType
• type RaftRPC
  • func (r *RaftRPC) Delete(c *Command, resp *string) error
  • func (r *RaftRPC) Get(c *Command, resp *string) error
  • func (r *RaftRPC) Set(c *Command, resp *string) error
• type Store
  • func (s *Store) Apply(l *raft.Log) interface{}
  • func (s *Store) Delete(key string)
  • func (s *Store) Get(key string) (string, bool)
  • func (s *Store) Restore(rc io.ReadCloser) error
  • func (s *Store) Set(key, value string)
  • func (s *Store) Snapshot() (raft.FSMSnapshot, error)

Functions

func SetDebug

func SetDebug(w io.Writer)

Types

type Command

type Command struct {
	Op    Op     `json:"op,omitempty"`
	Key   string `json:"key,omitempty"`
	Value string `json:"value,omitempty"`
}

type Config

type Config struct {
	Debug bool

	Dir string

	Addr string

	RetainSnapshotCount int

	EnableSingle bool

	RaftTimeout time.Duration

	StreamLayer raft.StreamLayer

	InitialPeers []string

	Logger *jolt.Logger
}

type Op

type Op int

const (
	Get Op = iota
	Set
	Delete
)

type Raft

type Raft struct {
	*raft.Raft

	RPC *RaftRPC
	// contains filtered or unexported fields
}

func NewRaft

func NewRaft(c *Config) (r *Raft, err error)

func (*Raft) Barrier

func (r *Raft) Barrier() error

func (*Raft) Config

func (r *Raft) Config() raft.Configuration

func (*Raft) Delete

func (r *Raft) Delete(key string) error

func (*Raft) Get

func (r *Raft) Get(key string) (string, error)

func (*Raft) IsLeader

func (r *Raft) IsLeader() bool

func (*Raft) Join

func (r *Raft) Join(id, addr string) error

func (*Raft) LocalID

func (r *Raft) LocalID() string

func (*Raft) Set

func (r *Raft) Set(key, value string) error

type RaftLayer

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

func NewRaftLayer

func NewRaftLayer(addr net.Addr) *RaftLayer

func (*RaftLayer) Accept

func (l *RaftLayer) Accept() (net.Conn, error)

func (*RaftLayer) Addr

func (l *RaftLayer) Addr() net.Addr

func (*RaftLayer) Close

func (l *RaftLayer) Close() error

func (*RaftLayer) Dial

func (l *RaftLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)

func (*RaftLayer) Handoff

func (l *RaftLayer) Handoff(c net.Conn) error

func (*RaftLayer) Type

func (l *RaftLayer) Type() rpc.RPCType

type RaftRPC

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

func (*RaftRPC) Delete

func (r *RaftRPC) Delete(c *Command, resp *string) error

func (*RaftRPC) Get

func (r *RaftRPC) Get(c *Command, resp *string) error

func (*RaftRPC) Set

func (r *RaftRPC) Set(c *Command, resp *string) error

type Store

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

func (*Store) Apply

func (s *Store) Apply(l *raft.Log) interface{}

func (*Store) Delete

func (s *Store) Delete(key string)

func (*Store) Get

func (s *Store) Get(key string) (string, bool)

func (*Store) Restore

func (s *Store) Restore(rc io.ReadCloser) error

func (*Store) Set

func (s *Store) Set(key, value string)

func (*Store) Snapshot

func (s *Store) Snapshot() (raft.FSMSnapshot, error)