manager/state/raft/transport/transport.go
Method Transport.Send
has 7 return statements (exceeds 4 allowed). Open
Open
func (t *Transport) Send(m raftpb.Message) error {
t.mu.Lock()
defer t.mu.Unlock()
if t.stopped {
return errors.New("transport stopped")
Method Transport.AddPeer
has 5 return statements (exceeds 4 allowed). Open
Open
func (t *Transport) AddPeer(id uint64, addr string) error {
t.mu.Lock()
defer t.mu.Unlock()
if t.stopped {
return errors.New("transport stopped")