transport

type Demultiplexer interface {
	Receive(ctx context.Context, msg *raftpb.Message, endpoint string) error
}

type Host interface {
	Sender
	Demultiplexer

	Stop()
	Register(node uint64, r Receiver)
}

type Multiplexer interface {
	Send(ctx context.Context, msg *raftpb.Message, cb SendCallback)
}

type Receiver interface {
	Receive(ctx context.Context, msg *raftpb.Message, from uint64, endpoint string)
}

type Resolver interface {
	Resolve(node uint64) string
}

type SendCallback func(error)

type Sender interface {
	Send(ctx context.Context, msg *raftpb.Message, to uint64, endpoint string, cb SendCallback)
}

type SimpleResolver struct {
	sync.RWMutex
	// contains filtered or unexported fields
}