etcd

Documentation

Index

• type Wrapper
  • func NewRaft(logger logrus.FieldLogger, sm raft.StateMachine, ...) *Wrapper
  • func (w *Wrapper) Handler() http.Handler
  • func (w *Wrapper) IsIDRemoved(id uint64) bool
  • func (w *Wrapper) Process(ctx context.Context, m raftpb.Message) error
  • func (w *Wrapper) ProposeCmd(ctx context.Context, req []byte) (raft.Future, error)
  • func (w *Wrapper) ProposeConf(ctx context.Context, req *commonpb.ReconfRequest) (raft.Future, error)
  • func (w *Wrapper) ReadCmd(context.Context, []byte) (raft.Future, error)
  • func (w *Wrapper) ReportSnapshot(id uint64, status etcdraft.SnapshotStatus)
  • func (w *Wrapper) ReportUnreachable(id uint64)

Types

type Wrapper

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

Wrapper wraps an etcd/raft.Node and implements relab/raft.Raft and etcd/rafthttp.Raft.

func NewRaft

func NewRaft(logger logrus.FieldLogger,
	sm raft.StateMachine, storage *etcdraft.MemoryStorage, wal *wal.WAL, cfg *etcdraft.Config,
	peers []etcdraft.Peer, heartbeat time.Duration,
	single bool, servers []string,
	lat *raft.Latency, event *raft.Event,
	leaderOut chan struct{},
) *Wrapper

func (*Wrapper) Handler

func (w *Wrapper) Handler() http.Handler

func (*Wrapper) IsIDRemoved

func (w *Wrapper) IsIDRemoved(id uint64) bool

func (*Wrapper) Process

func (w *Wrapper) Process(ctx context.Context, m raftpb.Message) error

func (*Wrapper) ProposeCmd

func (w *Wrapper) ProposeCmd(ctx context.Context, req []byte) (raft.Future, error)

func (*Wrapper) ProposeConf

func (w *Wrapper) ProposeConf(ctx context.Context, req *commonpb.ReconfRequest) (raft.Future, error)

func (*Wrapper) ReadCmd

func (w *Wrapper) ReadCmd(context.Context, []byte) (raft.Future, error)

func (*Wrapper) ReportSnapshot

func (w *Wrapper) ReportSnapshot(id uint64, status etcdraft.SnapshotStatus)

func (*Wrapper) ReportUnreachable

func (w *Wrapper) ReportUnreachable(id uint64)