189
ctx context.Context,
190
request *p.UpsertClusterMembershipRequest,
192
>
now := time.Now().UTC()
193
>
recordExpiry := now.Add(request.RecordExpiry)
194
>
_, err := s.DB.UpsertClusterMembership(ctx, &sqlplugin.ClusterMembershipRow{
195
>
Role: request.Role,
196
>
HostID: request.HostID,
197
>
RPCAddress: request.RPCAddress.String(),
198
>
RPCPort: request.RPCPort,
199
>
SessionStart: request.SessionStart,
200
>
LastHeartbeat: now,
201
>
RecordExpiry: recordExpiry})
202
>
203
>
if err != nil {
204
return convertCommonErrors("UpsertClusterMembership", err)
205
}
206
208
}
209