Skip to content

Commit 289a3da

Browse files
committed
Return error
1 parent d51f57c commit 289a3da

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

pkg/flypg/state/cluster.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,8 @@ func (c *ClusterState) RegisterMember(id int32, hostname string, region string,
6767
if errors.Is(err, ErrCAS) {
6868
c.RegisterMember(id, hostname, region, primary)
6969
}
70+
71+
return err
7072
}
7173

7274
return nil
@@ -92,6 +94,8 @@ func (c *ClusterState) UnregisterMember(id int32) error {
9294
if errors.Is(err, ErrCAS) {
9395
c.UnregisterMember(id)
9496
}
97+
98+
return err
9599
}
96100

97101
return nil
@@ -122,6 +126,8 @@ func (c *ClusterState) AssignPrimary(id int32) error {
122126
if errors.Is(err, ErrCAS) {
123127
c.AssignPrimary(id)
124128
}
129+
130+
return err
125131
}
126132

127133
return nil

0 commit comments

Comments
 (0)