110
hostID, _ := uuid.New().MarshalBinary()
111
if firstGetClusterMemberCall {
112
>
// The first time GetClusterMembers is invoked, we simulate returning a stale/bad heartbeat.
test_cluster.go
113
>
// All subsequent calls only return the single "good" seed member
114
>
// This ensures that we exercise the retry path in bootstrap properly.
115
>
badSeedMember := &persistence.ClusterMember{
116
>
HostID: hostID,
117
>
RPCAddress: seedAddress,
118
>
RPCPort: seedPort + 1,
119
>
SessionStart: time.Now().UTC(),
120
>
LastHeartbeat: time.Now().UTC(),
121
>
}
122
>
res = &persistence.GetClusterMembersResponse{ActiveMembers: []*persistence.ClusterMember{seedMember, badSeedMember}}
123
>
}
124
125
firstGetClusterMemberCall = false