leader existence check when calling leader

ksrichard · Dec 3, 2021 · c344fd0 · c344fd0
1 parent 53a1f9f
commit c344fd0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/client.go b/client.go
@@ -2,11 +2,15 @@ package easyraft
 
 import (
 	"context"
+	"errors"
 	"github.com/ksrichard/easyraft/grpc"
 	ggrpc "google.golang.org/grpc"
 )
 
 func ApplyOnLeader(node *Node, payload []byte) (interface{}, error) {
+	if node.Raft.Leader() == "" {
+		return nil, errors.New("unknown leader")
+	}
 	var opt ggrpc.DialOption = ggrpc.EmptyDialOption{}
 	conn, err := ggrpc.Dial(string(node.Raft.Leader()), ggrpc.WithInsecure(), ggrpc.WithBlock(), opt)
 	if err != nil {