ctx context.Context,
row *sqlplugin.ClusterMembershipRow,
return mdb.ExecContext(ctx,
templateUpsertActiveClusterMembership,
constMembershipPartition,
row.HostID,
row.RPCAddress,
row.RPCPort,
row.Role,
mdb.converter.ToMySQLDateTime(row.SessionStart),
mdb.converter.ToMySQLDateTime(row.LastHeartbeat),
mdb.converter.ToMySQLDateTime(row.RecordExpiry))
}
func (mdb *db) GetClusterMembers(