61
62
// TestClusterMembershipUpsertCanReadAny verifies that we can UpsertClusterMembership and read our result
63
>
func (s *ClusterMetadataManagerSuite) TestClusterMembershipUpsertCanReadAny() {
cluster_metadata_manager.go
64
>
hostID, err := uuid.New().MarshalBinary()
65
>
s.NoError(err)
66
>
req := &p.UpsertClusterMembershipRequest{
67
>
HostID: hostID,
68
>
RPCAddress: net.ParseIP("127.0.0.2"),
69
>
RPCPort: 123,
70
>
Role: p.Frontend,
71
>
SessionStart: time.Now().UTC(),
72
>
RecordExpiry: time.Second,
73
>
}
74
>
75
>
err = s.ClusterMetadataManager.UpsertClusterMembership(s.ctx, req)
76
>
s.Nil(err)
77
>
78
>
resp, err := s.ClusterMetadataManager.GetClusterMembers(s.ctx, &p.GetClusterMembersRequest{})
79
>
80
>
s.Nil(err)
81
>
s.NotNil(resp)
82
>
s.NotEmpty(resp.ActiveMembers)
83
>
84
>
s.waitForPrune(5 * time.Second)
85
>
}
86
87
// TestClusterMembershipUpsertCanPageRead verifies that we can UpsertClusterMembership and read our result